Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

removed unused executor 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638246 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-03-18 07:15:45 +00:00
parent e41be74339
commit 3957eb0f6d
1 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
View File

@ -26,15 +26,11 @@ import java.util.List;
import java.util.Random; import java.util.Random;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import org.apache.activemq.command.BrokerInfo; import org.apache.activemq.command.BrokerInfo;
import org.apache.activemq.command.Command; import org.apache.activemq.command.Command;
import org.apache.activemq.command.ConnectionControl; import org.apache.activemq.command.ConnectionControl;
import org.apache.activemq.command.Message;
import org.apache.activemq.command.RemoveInfo; import org.apache.activemq.command.RemoveInfo;
import org.apache.activemq.command.Response; import org.apache.activemq.command.Response;
import org.apache.activemq.state.ConnectionStateTracker; import org.apache.activemq.state.ConnectionStateTracker;
@ -79,7 +75,6 @@ public class FailoverTransport implements CompositeTransport {
private URI failedConnectTransportURI; private URI failedConnectTransportURI;
private final AtomicReference<Transport> connectedTransport = new AtomicReference<Transport>(); private final AtomicReference<Transport> connectedTransport = new AtomicReference<Transport>();
private final TaskRunner reconnectTask; private final TaskRunner reconnectTask;
private final ExecutorService executor;
private boolean started; private boolean started;
private long initialReconnectDelay = 10; private long initialReconnectDelay = 10;
@ -107,14 +102,6 @@ public class FailoverTransport implements CompositeTransport {
public FailoverTransport() throws InterruptedIOException { public FailoverTransport() throws InterruptedIOException {
stateTracker.setTrackTransactions(true); stateTracker.setTrackTransactions(true);
this.executor = Executors.newSingleThreadExecutor(new ThreadFactory() {
public Thread newThread(Runnable runnable) {
Thread thread = new Thread(runnable, "FailoverTransport:"+toString()+"."+System.identityHashCode(this));
thread.setDaemon(true);
thread.setPriority(Thread.NORM_PRIORITY);
return thread;
}
});
// Setup a task that is used to reconnect the a connection async. // Setup a task that is used to reconnect the a connection async.
reconnectTask = DefaultThreadPools.getDefaultTaskRunnerFactory().createTaskRunner(new Task() { reconnectTask = DefaultThreadPools.getDefaultTaskRunnerFactory().createTaskRunner(new Task() {
public boolean iterate() { public boolean iterate() {
@ -276,7 +263,6 @@ public class FailoverTransport implements CompositeTransport {
sleepMutex.notifyAll(); sleepMutex.notifyAll();
} }
reconnectTask.shutdown(); reconnectTask.shutdown();
executor.shutdown();
if( transportToStop!=null ) { if( transportToStop!=null ) {
transportToStop.stop(); transportToStop.stop();
} }