svn commit: r638235 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

[rajdavies]

Author: rajdavies
Date: Mon Mar 17 23:38:18 2008
New Revision: 638235

URL: http://svn.apache.org/viewvc?rev=638235&view=rev
Log:
Use ThreadPool for stopping services

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=638235&r1=638234&r2=638235&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
 Mon Mar 17 23:38:18 2008
@@ -379,12 +379,11 @@
                 LOG.warn("Network connection between " + localBroker + " and " 
+ remoteBroker + " shutdown due to a remote error: " + error);
             }
             LOG.debug("The remote Exception was: " + error, error);
-            new Thread() {
-
+            ASYNC_TASKS.execute(new Runnable() {
                 public void run() {
                     ServiceSupport.dispose(DemandForwardingBridgeSupport.this);
                 }
-            }.start();
+            });
             fireBridgeFailed();
         }
     }
@@ -532,11 +531,11 @@
         if (!disposed) {
             LOG.info("Network connection between " + localBroker + " and " + 
remoteBroker + " shutdown due to a local error: " + error);
             LOG.debug("The local Exception was:" + error, error);
-            new Thread() {
+            ASYNC_TASKS.execute(new Runnable() {
                 public void run() {
                     ServiceSupport.dispose(DemandForwardingBridgeSupport.this);
                 }
-            }.start();
+            });
             fireBridgeFailed();
         }
     }