diff --git a/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java b/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java index 93b319f482..836002e458 100644 --- a/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java +++ b/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java @@ -54,6 +54,10 @@ public class ConduitBridge extends DemandForwardingBridge{ } protected boolean addToAlreadyInterestedConsumers(ConsumerInfo info){ + + if( info.getSelector()!=null ) + return false; + //search through existing subscriptions and see if we have a match boolean matched = false; DestinationFilter filter=DestinationFilter.parseFilter(info.getDestination());