activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r418164 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnector.java
Date Fri, 30 Jun 2006 02:20:09 GMT
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() {



Mime
View raw message