Minor change, improved a bit logging messages quality
This commit is contained in:
+2
-1
@@ -158,7 +158,6 @@ public class HawtDBStorageService implements IStorageService {
|
||||
}
|
||||
|
||||
public void storePublishForFuture(PublishEvent evt) {
|
||||
LOG.debug("storePublishForFuture store evt " + evt);
|
||||
List<PublishEvent> storedEvents;
|
||||
String clientID = evt.getClientID();
|
||||
if (!m_persistentMessageStore.containsKey(clientID)) {
|
||||
@@ -168,6 +167,8 @@ public class HawtDBStorageService implements IStorageService {
|
||||
}
|
||||
storedEvents.add(evt);
|
||||
m_persistentMessageStore.put(clientID, storedEvents);
|
||||
LOG.debug(String.format("Stored published message for client <%s> on topic <%s>, content %s",
|
||||
clientID, evt.getTopic(), new String(evt.getMessage())));
|
||||
}
|
||||
|
||||
public List<PublishEvent> retrivePersistedPublishes(String clientID) {
|
||||
|
||||
+1
-1
@@ -166,7 +166,7 @@ public class SubscriptionsStore {
|
||||
}
|
||||
|
||||
public void activate(String clientID) {
|
||||
LOG.debug("activate re-activating subscriptions for clientID " + clientID);
|
||||
LOG.debug(String.format("Activating subscriptions for clientID <%s>", clientID));
|
||||
subscriptions.activate(clientID);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user