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
This commit is contained in:
Hiram R. Chirino 2006-06-30 02:20:08 +00:00
parent 24d8986cee
commit a53b2e80c6
1 changed files with 1 additions and 1 deletions

View File

@ -53,7 +53,7 @@ public class ManagedTransportConnector extends TransportConnector {
protected Connection createConnection(Transport transport) throws IOException { protected Connection createConnection(Transport transport) throws IOException {
String connectionId = "" + getNextConnectionId(); 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() { protected static synchronized long getNextConnectionId() {