anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Minor change, condensed debug logging

Browse Source
This commit is contained in:
andrea
2013-12-26 11:45:52 +01:00
parent a020d83c8a
commit 42311b2c54
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java
+3 -4
View File
@@ -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) {