Moved QoS1 publish handling to separate class

2016-12-13 23:43:02 +01:00
parent 81a447dce9
commit d65886343b
3 changed files with 219 additions and 60 deletions
@@ -76,7 +76,7 @@ public class Qos0PublishHandler {
        return false;
    }

-    void publish2Subscribers_qos0(IMessagesStore.StoredMessage pubMsg, List<Subscription> topicMatchingSubscriptions) {
+    private void publish2Subscribers_qos0(IMessagesStore.StoredMessage pubMsg, List<Subscription> topicMatchingSubscriptions) {
        final String topic = pubMsg.getTopic();
        final ByteBuffer origMessage = pubMsg.getMessage();
        LOG.debug("publish2Subscribers republishing to existing subscribers that matches the topic {}", topic);