svn commit: r430068 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java

[rajdavies]

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
             }