You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@activemq.apache.org by ra...@apache.org on 2006/07/21 09:31:52 UTC

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

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();