diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java index 59ffe6bc..2c8da612 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java @@ -200,6 +200,7 @@ public class SubscriptionsStore { * client's topics subscriptions */ public void init(MultiIndexFactory multiFactory) { + LOG.debug("init invoked"); BTreeIndexFactory> indexFactory = new BTreeIndexFactory>(); indexFactory.setKeyCodec(StringCodec.INSTANCE); @@ -210,6 +211,7 @@ public class SubscriptionsStore { LOG.debug("Reloading all stored subscriptions..."); for (Map.Entry> entry : m_persistent) { for (Subscription subscription : entry.getValue()) { + LOG.debug("Re-subscribing " + subscription.getClientId() + " to topic " + subscription.getTopic()); addDirect(subscription); } }