Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4026: correct connection-router related log statement value and/or level

This commit is contained in:
Robbie Gemmell 2022-10-03 15:11:06 +01:00
parent 9647e6555f
commit f465073744
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/caches/LocalCache.java
View File

@ -76,7 +76,8 @@ public class LocalCache implements Cache, RemovalListener<String, String> {
if (persistedCacheEntries != null) { if (persistedCacheEntries != null) {
for (Map.Entry<String, PersistedKeyValuePair> cacheEntry : persistedCacheEntries.entrySet()) { for (Map.Entry<String, PersistedKeyValuePair> cacheEntry : persistedCacheEntries.entrySet()) {
cache.put(cacheEntry.getKey(), cacheEntry.getValue().getValue()); cache.put(cacheEntry.getKey(), cacheEntry.getValue().getValue());
logger.info(cacheEntry.toString());
logger.debug("Restored persisted cache entry during start: {}", cacheEntry);
} }
} }
} }

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java
View File

@ -59,7 +59,7 @@ public class LeastConnectionsPolicy extends RoundRobinPolicy {
connectionCount = 0; connectionCount = 0;
} else if (logger.isDebugEnabled()) { } else if (logger.isDebugEnabled()) {
logger.debug("Updating the connection count to 0/" + connectionCount + " for the target " + target); logger.debug("Updating the connection count to " + connectionCount + " for the target " + target);
} }
connectionCountCache.put(target, connectionCount); connectionCountCache.put(target, connectionCount);