Author: chirino
Date: Thu Jun 29 19:20:08 2006
New Revision: 418164
URL: http://svn.apache.org/viewvc?rev=418164&view=rev
Log:
Allow the connector to override if async dispatch is allowed.
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java?rev=418164&r1=418163&r2=418164&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
Thu Jun 29 19:20:08 2006
@@ -53,7 +53,7 @@
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() {
