From 42311b2c54b2781c5b75e95f47985db074fd08a6 Mon Sep 17 00:00:00 2001 From: andrea Date: Thu, 26 Dec 2013 11:45:52 +0100 Subject: [PATCH] Minor change, condensed debug logging --- .../spi/impl/subscriptions/SubscriptionsStore.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java index a6ff1fc3..240c7ccc 100644 --- a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java +++ b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java @@ -71,17 +71,16 @@ public class SubscriptionsStore { //reload any subscriptions persisted if (LOG.isDebugEnabled()) { - LOG.debug("subscription tree before {}", dumpTree()); + LOG.debug("Reloading all stored subscriptions...subscription tree before {}", dumpTree()); } - LOG.debug("Reloading all stored subscriptions..."); + for (Subscription subscription : m_storageService.retrieveAllSubscriptions()) { LOG.debug("Re-subscribing {} to topic {}", subscription.getClientId(), subscription.getTopic()); addDirect(subscription); } if (LOG.isDebugEnabled()) { - LOG.debug("subscription tree after {}", dumpTree()); + LOG.debug("Finished loading. Subscription tree after {}", dumpTree()); } - LOG.debug("Finished loading"); } protected void addDirect(Subscription newSubscription) {