You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/07/11 06:41:49 UTC
svn commit: r420721 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
Author: chirino
Date: Mon Jul 10 21:41:48 2006
New Revision: 420721
URL: http://svn.apache.org/viewvc?rev=420721&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-810
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java?rev=420721&r1=420720&r2=420721&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java Mon Jul 10 21:41:48 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());