commit a5f06025057afb927d00c941412d1143c8614098
author Jean-Baptiste Onofré <jbonofre@apache.org> Fri Oct 18 19:09:32 2019 +0200
committer GitHub <noreply@github.com> Fri Oct 18 19:09:32 2019 +0200
tree 29425af2168dff5964ed598745945f8c68551671
parent 17c417e8084193b6643f4e5f81acb2bf7a8b8392
parent 86a069ac5db9742ae58e396e162a0b3e2bdc66c3

Merge pull request #395 from couclock/AMQ-7312

AMQ-7312 virtualSelectorCacheBrokerPlugin addConsumer issue

activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java

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 2d31b6e..bc55eac 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
@@ -131,8 +131,10 @@
 
     @Override
     public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
-        // don't track selectors for advisory topics or temp destinations
-        if (!AdvisorySupport.isAdvisoryTopic(info.getDestination()) && !info.getDestination().isTemporary()) {
+		// don't track selectors for advisory topics, temp destinations or console
+		// related consumers
+		if (!AdvisorySupport.isAdvisoryTopic(info.getDestination()) && !info.getDestination().isTemporary()
+				&& !info.isBrowser()) {
             String destinationName = info.getDestination().getQualifiedName();
             LOG.debug("Caching consumer selector [{}] on  '{}'", info.getSelector(), destinationName);