From 4f131fdc2686c441a6ce3e2c68346fb64fb886fa Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Fri, 21 Jul 2006 07:31:52 +0000 Subject: [PATCH] ensure Desitnation infomation is received in the bridge in the right order with respect to consumer information git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@424214 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/activemq/network/DemandForwardingBridgeSupport.java | 1 + 1 file changed, 1 insertion(+) diff --git a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java index fb5cd408fa..a8c33373ce 100644 --- a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java +++ b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java @@ -269,6 +269,7 @@ public abstract class DemandForwardingBridgeSupport implements Bridge { 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();