activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r430068 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
Date Wed, 09 Aug 2006 15:10:26 GMT
Author: rajdavies
Date: Wed Aug  9 08:10:26 2006
New Revision: 430068

URL: http://svn.apache.org/viewvc?rev=430068&view=rev
Log:
applied patch for http://issues.apache.org/activemq/browse/AMQ-776

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=430068&r1=430067&r2=430068&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
Wed Aug  9 08:10:26 2006
@@ -66,7 +66,8 @@
             DemandSubscription ds = (DemandSubscription)i.next();
             if (filter.matches(ds.getLocalInfo().getDestination())){
                 //add the interest in the subscription
-                ds.add(ds.getRemoteInfo().getConsumerId());
+                //ds.add(ds.getRemoteInfo().getConsumerId());
+                ds.add(info.getConsumerId());
                 matched = true;
                 //continue - we want interest to any existing DemandSubscriptions
             }



Mime
View raw message