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

[rajdavies]

Author: rajdavies
Date: Tue Mar 18 00:15:45 2008
New Revision: 638246

URL: http://svn.apache.org/viewvc?rev=638246&view=rev
Log:
removed unused executor

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=638246&r1=638245&r2=638246&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
 Tue Mar 18 00:15:45 2008
@@ -26,15 +26,11 @@
 import java.util.Random;
 import java.util.concurrent.ConcurrentHashMap;
 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 org.apache.activemq.command.BrokerInfo;
 import org.apache.activemq.command.Command;
 import org.apache.activemq.command.ConnectionControl;
-import org.apache.activemq.command.Message;
 import org.apache.activemq.command.RemoveInfo;
 import org.apache.activemq.command.Response;
 import org.apache.activemq.state.ConnectionStateTracker;
@@ -79,7 +75,6 @@
     private URI failedConnectTransportURI;
     private final AtomicReference<Transport> connectedTransport = new 
AtomicReference<Transport>();
     private final TaskRunner reconnectTask;
-    private final ExecutorService executor;
     private boolean started;
 
     private long initialReconnectDelay = 10;
@@ -107,14 +102,6 @@
     public FailoverTransport() throws InterruptedIOException {
 
         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.
         reconnectTask = 
DefaultThreadPools.getDefaultTaskRunnerFactory().createTaskRunner(new Task() {
             public boolean iterate() {
@@ -276,7 +263,6 @@
             sleepMutex.notifyAll();
         }
         reconnectTask.shutdown();
-        executor.shutdown();
         if( transportToStop!=null ) {
             transportToStop.stop();
         }