anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Removed unused params

Browse Source
This commit is contained in:
andsel
2016-12-13 23:43:02 +01:00
parent 2b554ca475
commit c76db85ae7
3 changed files with 4 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/spi/impl/MetaPublisher.java
+2 -4
View File
@@ -1,14 +1,12 @@
package io.moquette.spi.impl;
import io.moquette.parser.proto.messages.AbstractMessage;
import io.moquette.parser.proto.messages.PublishMessage;
import io.moquette.server.ConnectionDescriptor;
import io.moquette.spi.ClientSession;
import io.moquette.spi.IMessagesStore;
import io.moquette.spi.ISessionsStore;
import io.moquette.spi.MessageGUID;
import io.moquette.spi.impl.subscriptions.Subscription;
import io.netty.channel.Channel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -32,8 +30,8 @@ class MetaPublisher {
this.connectionDescriptors = connectionDescriptors;
this.m_sessionsStore = sessionsStore;
this.m_messagesStore = messagesStore;
this.qos0Publisher = new Qos0Publisher(connectionDescriptors, sessionsStore);
this.qos2Publisher = new Qos2Publisher(connectionDescriptors, sessionsStore, m_messagesStore);
this.qos0Publisher = new Qos0Publisher(connectionDescriptors);
this.qos2Publisher = new Qos2Publisher(connectionDescriptors);
}
void publish2Subscribers(IMessagesStore.StoredMessage pubMsg, List<Subscription> topicMatchingSubscriptions) {
broker/src/main/java/io/moquette/spi/impl/Qos0Publisher.java
+1 -7
View File
@@ -4,26 +4,20 @@ import io.moquette.parser.proto.messages.AbstractMessage;
import io.moquette.parser.proto.messages.PublishMessage;
import io.moquette.server.ConnectionDescriptor;
import io.moquette.spi.ClientSession;
import io.moquette.spi.IMessagesStore;
import io.moquette.spi.ISessionsStore;
import io.moquette.spi.impl.subscriptions.Subscription;
import io.netty.channel.Channel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.nio.ByteBuffer;
import java.util.List;
import java.util.concurrent.ConcurrentMap;
class Qos0Publisher {
private static final Logger LOG = LoggerFactory.getLogger(Qos0Publisher.class);
private final ConcurrentMap<String, ConnectionDescriptor> connectionDescriptors;
private final ISessionsStore m_sessionsStore;
public Qos0Publisher(ConcurrentMap<String, ConnectionDescriptor> connectionDescriptors, ISessionsStore sessionsStore) {
public Qos0Publisher(ConcurrentMap<String, ConnectionDescriptor> connectionDescriptors) {
this.connectionDescriptors = connectionDescriptors;
this.m_sessionsStore = sessionsStore;
}
void publishQos0(ClientSession clientsession, String topic, ByteBuffer message) {
broker/src/main/java/io/moquette/spi/impl/Qos2Publisher.java
+1 -8
View File
@@ -4,8 +4,6 @@ import io.moquette.parser.proto.messages.AbstractMessage;
import io.moquette.parser.proto.messages.PublishMessage;
import io.moquette.server.ConnectionDescriptor;
import io.moquette.spi.ClientSession;
import io.moquette.spi.IMessagesStore;
import io.moquette.spi.ISessionsStore;
import io.netty.channel.Channel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -17,14 +15,9 @@ class Qos2Publisher {
private static final Logger LOG = LoggerFactory.getLogger(Qos2Publisher.class);
private final ConcurrentMap<String, ConnectionDescriptor> connectionDescriptors;
private final ISessionsStore m_sessionsStore;
private final IMessagesStore m_messagesStore;
public Qos2Publisher(ConcurrentMap<String, ConnectionDescriptor> connectionDescriptors, ISessionsStore sessionsStore,
IMessagesStore messagesStore) {
public Qos2Publisher(ConcurrentMap<String, ConnectionDescriptor> connectionDescriptors) {
this.connectionDescriptors = connectionDescriptors;
this.m_sessionsStore = sessionsStore;
m_messagesStore = messagesStore;
}
void publishQos2(ClientSession clientsession, String topic, AbstractMessage.QOSType qos,