Author: chirino
Date: Mon Jul 10 21:40:49 2006
New Revision: 420720
URL: http://svn.apache.org/viewvc?rev=420720&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-810
Modified:
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
Modified:
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java?rev=420720&r1=420719&r2=420720&view=diff
==============================================================================
---
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
(original)
+++
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
Mon Jul 10 21:40:49 2006
@@ -54,6 +54,10 @@
}
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());