From f0064357f5d149eca2e9b57dd47567a7f30717e8 Mon Sep 17 00:00:00 2001
From: andrea <andrea@samarcanda>
Date: Mon, 27 Aug 2012 11:36:26 +0200
Subject: [PATCH] Minor change added a log

---
 .../mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java    | 2 ++
 1 file changed, 2 insertions(+)

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<String, List<Subscription>> indexFactory =
                 new BTreeIndexFactory<String, List<Subscription>>();
         indexFactory.setKeyCodec(StringCodec.INSTANCE);
@@ -210,6 +211,7 @@ public class SubscriptionsStore {
         LOG.debug("Reloading all stored subscriptions...");
         for (Map.Entry<String, List<Subscription>> entry : m_persistent) {
             for (Subscription subscription : entry.getValue()) {
+                LOG.debug("Re-subscribing " + subscription.getClientId() + " to topic " + subscription.getTopic());
                 addDirect(subscription);
             }
         }