svn commit: r418162 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java

[chirino]

Author: chirino
Date: Thu Jun 29 18:43:12 2006
New Revision: 418162

URL: http://svn.apache.org/viewvc?rev=418162&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/TransportConnector.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java?rev=418162&r1=418161&r2=418162&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
 Thu Jun 29 18:43:12 2006
@@ -64,6 +64,7 @@
     private URI discoveryUri;
     private URI connectUri;
     private String name;
+    private boolean disableAsyncDispatch=false;
 
 
     /**
@@ -94,6 +95,7 @@
         rc.setDiscoveryAgent(discoveryAgent);
         rc.setDiscoveryUri(discoveryUri);
         rc.setName(name);
+        rc.setDisableAsyncDispatch(disableAsyncDispatch);
         return rc;
     }
     
@@ -228,7 +230,7 @@
     // Implementation methods
     // 
-------------------------------------------------------------------------
     protected Connection createConnection(Transport transport) throws 
IOException {
-        TransportConnection answer = new TransportConnection(this, transport, 
broker, taskRunnerFactory);
+        TransportConnection answer = new TransportConnection(this, transport, 
broker, disableAsyncDispatch ? null : taskRunnerFactory);
         answer.setMessageAuthorizationPolicy(messageAuthorizationPolicy);
         return answer;
     }
@@ -303,4 +305,12 @@
     public String toString() {
         return getName();
     }
+
+       public boolean isDisableAsyncDispatch() {
+               return disableAsyncDispatch;
+       }
+
+       public void setDisableAsyncDispatch(boolean disableAsyncDispatch) {
+               this.disableAsyncDispatch = disableAsyncDispatch;
+       }
 }