activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r424214 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Fri, 21 Jul 2006 07:31:52 GMT
Author: rajdavies
Date: Fri Jul 21 00:31:52 2006
New Revision: 424214

URL: http://svn.apache.org/viewvc?rev=424214&view=rev
Log:
ensure Desitnation infomation is received in the bridge in the right order
with respect to consumer information

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=424214&r1=424213&r2=424214&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Fri Jul 21 00:31:52 2006
@@ -269,6 +269,7 @@
                 ConsumerInfo destinationInfo  = new ConsumerInfo(remoteSessionInfo,2);
                 destinationInfo.setDestination(AdvisorySupport.TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC);
                 destinationInfo.setPrefetchSize(prefetchSize);
+                destinationInfo.setDispatchAsync(dispatchAsync);
                 remoteBroker.oneway(destinationInfo);
                 startedLatch.countDown();
                 



Mime
View raw message