From a53b2e80c6232b33b119eec9df00bc440dd1c4fb Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Fri, 30 Jun 2006 02:20:08 +0000
Subject: [PATCH] Allow the connector to override if async dispatch is allowed.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@418164 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/activemq/broker/jmx/ManagedTransportConnector.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
index a772b04f60..8a891b5e94 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
@@ -53,7 +53,7 @@ public class ManagedTransportConnector extends TransportConnector {
 
     protected Connection createConnection(Transport transport) throws IOException {
         String connectionId = "" + getNextConnectionId();
-        return new ManagedTransportConnection(this, transport, getBroker(), getTaskRunnerFactory(), mbeanServer, connectorName, connectionId);
+        return new ManagedTransportConnection(this, transport, getBroker(), isDisableAsyncDispatch() ? null : getTaskRunnerFactory(), mbeanServer, connectorName, connectionId);
     }
 
     protected static synchronized long getNextConnectionId() {