[activemq] branch activemq-5.15.x updated: AMQ-7404 add debug logging for selectors loaded from the cache file

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[activemq] branch activemq-5.15.x updated: AMQ-7404 add debug logging for selectors loaded from the cache file

jbonofre-2
This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/activemq-5.15.x by this push:
     new c78e9b1  AMQ-7404 add debug logging for selectors loaded from the cache file
c78e9b1 is described below

commit c78e9b11c4d2f4afbb8e621336666bae82dc7c20
Author: Jonathan Gallimore <[hidden email]>
AuthorDate: Wed Feb 12 11:15:59 2020 +0000

    AMQ-7404 add debug logging for selectors loaded from the cache file
   
    (cherry picked from commit e6befbc8750127d3f1a0a36eec91507b57aef2ab)
---
 .../apache/activemq/plugin/SubQueueSelectorCacheBroker.java | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java b/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
index bc55eac..ecea02f 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
@@ -194,7 +194,20 @@ public class SubQueueSelectorCacheBroker extends BrokerFilter implements Runnabl
                 try (FileInputStream fis = new FileInputStream(persistFile);) {
                     ObjectInputStream in = new ObjectInputStream(fis);
                     try {
+                        LOG.debug("Reading selector cache....");
                         subSelectorCache = (ConcurrentHashMap<String, Set<String>>) in.readObject();
+
+                        if (LOG.isDebugEnabled()) {
+                            final StringBuilder sb = new StringBuilder();
+                            sb.append("Selector cache data loaded from: ").append(persistFile.getAbsolutePath()).append("\n");
+                            sb.append("The following entries were loaded from the cache file: \n");
+
+                            subSelectorCache.forEach((k,v) -> {
+                                sb.append("\t").append(k).append(": ").append(v).append("\n");
+                            });
+
+                            LOG.debug(sb.toString());
+                        }
                     } catch (ClassNotFoundException ex) {
                         LOG.error("Invalid selector cache data found. Please remove file.", ex);
                     } finally {