activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r638235 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Tue, 18 Mar 2008 06:38:20 GMT
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();
         }
     }



Mime
View raw message