From 296af8b4f6b7b54e08c62446da1457d9299d0f35 Mon Sep 17 00:00:00 2001 From: andsel Date: Fri, 9 Dec 2016 13:23:59 +0100 Subject: [PATCH] Renamed route2Subscribers() to publish2Subscribers() --- .../io/moquette/spi/impl/ProtocolProcessor.java | 14 +++++++------- .../moquette/spi/impl/ProtocolProcessorTest.java | 2 +- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java index ec03476a..71a43bc5 100644 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java @@ -463,7 +463,7 @@ public class ProtocolProcessor { toStoreMsg.setClientID(clientID); List topicMatchingSubscriptions = subscriptions.matches(topic); - route2Subscribers(toStoreMsg, topicMatchingSubscriptions); + publish2Subscribers(toStoreMsg, topicMatchingSubscriptions); if (msg.isRetainFlag()) { //QoS == 0 && retain => clean old retained @@ -497,7 +497,7 @@ public class ProtocolProcessor { String clientID = NettyUtils.clientID(channel); toStoreMsg.setClientID(clientID); List topicMatchingSubscriptions = subscriptions.matches(topic); - route2Subscribers(toStoreMsg, topicMatchingSubscriptions); + publish2Subscribers(toStoreMsg, topicMatchingSubscriptions); //send PUBACK final Integer messageID = msg.getMessageID(); @@ -577,7 +577,7 @@ public class ProtocolProcessor { guid = m_messagesStore.storePublishForFuture(toStoreMsg); } List topicMatchingSubscriptions = subscriptions.matches(topic); - route2Subscribers(toStoreMsg, topicMatchingSubscriptions); + publish2Subscribers(toStoreMsg, topicMatchingSubscriptions); if (!msg.isRetainFlag()) { return; @@ -610,18 +610,18 @@ public class ProtocolProcessor { tobeStored.setMessageID(messageId); String topic = tobeStored.getTopic(); List topicMatchingSubscriptions = subscriptions.matches(topic); - route2Subscribers(tobeStored, topicMatchingSubscriptions); + publish2Subscribers(tobeStored, topicMatchingSubscriptions); } /** * Flood the subscribers with the message to notify. MessageID is optional and should only used for QoS 1 and 2 * */ - void route2Subscribers(IMessagesStore.StoredMessage pubMsg, List topicMatchingSubscriptions) { + void publish2Subscribers(IMessagesStore.StoredMessage pubMsg, List topicMatchingSubscriptions) { final String topic = pubMsg.getTopic(); final AbstractMessage.QOSType publishingQos = pubMsg.getQos(); final ByteBuffer origMessage = pubMsg.getMessage(); - LOG.debug("route2Subscribers republishing to existing subscribers that matches the topic {}", topic); + LOG.debug("publish2Subscribers republishing to existing subscribers that matches the topic {}", topic); if (LOG.isTraceEnabled()) { LOG.trace("content <{}>", DebugUtils.payload2Str(origMessage)); LOG.trace("subscription tree {}", subscriptions.dumpTree()); @@ -752,7 +752,7 @@ public class ProtocolProcessor { IMessagesStore.StoredMessage evt = targetSession.storedMessage(messageID); final String topic = evt.getTopic(); List topicMatchingSubscriptions = subscriptions.matches(topic); - route2Subscribers(evt, topicMatchingSubscriptions); + publish2Subscribers(evt, topicMatchingSubscriptions); if (evt.isRetained()) { if (!evt.getMessage().hasRemaining()) { diff --git a/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java b/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java index b6910740..2354e6aa 100644 --- a/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java +++ b/broker/src/test/java/io/moquette/spi/impl/ProtocolProcessorTest.java @@ -492,7 +492,7 @@ public class ProtocolProcessorTest { //Exercise List topicMatchingSubscriptions = subscriptions.matches(topic); - processor.route2Subscribers(forwardPublish, topicMatchingSubscriptions); + processor.publish2Subscribers(forwardPublish, topicMatchingSubscriptions); //Verify assertEquals(2, publishedForwarded.size());