Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-24 02:54:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

AMQ-7312 virtualSelectorCacheBrokerPlugin addConsumer issue

Browse Source 
(cherry picked from commit 86a069ac5db9742ae58e396e162a0b3e2bdc66c3)
This commit is contained in:
Dany LECOQ 2019-09-29 16:18:24 +02:00 committed by Jean-Baptiste Onofré
parent 9c994d98cf
commit 1d8ae314bd
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -131,8 +131,10 @@ public class SubQueueSelectorCacheBroker extends BrokerFilter implements Runnabl
@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);