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

[rajdavies]

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