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() {