You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/02/29 10:22:06 UTC

svn commit: r632269 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

Author: rajdavies
Date: Fri Feb 29 01:22:02 2008
New Revision: 632269

URL: http://svn.apache.org/viewvc?rev=632269&view=rev
Log:
Move back to using DEfaultThreadPools for reconnect tasks - as 
for very bad connections, DedicatedTaskRunner could get swamped with
reconnect tasks

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=632269&r1=632268&r2=632269&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java Fri Feb 29 01:22:02 2008
@@ -37,7 +37,7 @@
 import org.apache.activemq.command.Response;
 import org.apache.activemq.state.ConnectionStateTracker;
 import org.apache.activemq.state.Tracked;
-import org.apache.activemq.thread.DeterministicTaskRunner;
+import org.apache.activemq.thread.DefaultThreadPools;
 import org.apache.activemq.thread.Task;
 import org.apache.activemq.thread.TaskRunner;
 import org.apache.activemq.transport.CompositeTransport;
@@ -111,7 +111,7 @@
             }
         });
         // Setup a task that is used to reconnect the a connection async.
-        reconnectTask = new DeterministicTaskRunner(this.executor,new Task() {
+        reconnectTask = DefaultThreadPools.getDefaultTaskRunnerFactory().createTaskRunner(new Task() {
             public boolean iterate() {
             	boolean result=false;
             	boolean buildBackup=true;
@@ -133,7 +133,7 @@
             	return result;
             }
 
-        });
+        }, "ActiveMQ Failover Worker: " + System.identityHashCode(this));
     }
 
     TransportListener createTransportListener() {