From baab4b209ec23e59b4d389e18aeea2c6fc324506 Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Thu, 16 Mar 2006 14:11:00 +0000
Subject: [PATCH] Also set the dispatchAsync when using connection consumers
 (use in MDB dispatching).

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386335 13f79535-47bb-0310-9956-ffa450edef68
---
 .../src/main/java/org/apache/activemq/ActiveMQConnection.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
index 4e52792f82..08c40bf341 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -656,6 +656,7 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
         info.setSubcriptionName(subscriptionName);
         info.setSelector(messageSelector);
         info.setPrefetchSize(maxMessages);
+        info.setDispatchAsync(asyncDispatch);
 
         // Allows the options on the destination to configure the consumerInfo
         if( info.getDestination().getOptions()!=null ) {
@@ -963,12 +964,14 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
         
         checkClosedOrFailed();
         ensureConnectionInfoSent();
+        
         ConsumerId consumerId = createConsumerId();
         ConsumerInfo info = new ConsumerInfo(consumerId);
         info.setDestination(ActiveMQMessageTransformation.transformDestination(destination));
         info.setSelector(messageSelector);
         info.setPrefetchSize(maxMessages);
         info.setNoLocal(noLocal);
+        info.setDispatchAsync(asyncDispatch);
         
         // Allows the options on the destination to configure the consumerInfo
         if( info.getDestination().getOptions()!=null ) {