activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r418162 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
Date Fri, 30 Jun 2006 01:43:13 GMT
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;
+	}
 }



Mime
View raw message