activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r797052 - /activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java
Date Thu, 23 Jul 2009 12:58:54 GMT
Author: dejanb
Date: Thu Jul 23 12:58:53 2009
New Revision: 797052

URL: http://svn.apache.org/viewvc?rev=797052&view=rev
Log:
fix for https://issues.apache.org/activemq/browse/AMQ-2069 - thread deadlock in endpoint worker

Modified:
    activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java

Modified: activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java?rev=797052&r1=797051&r2=797052&view=diff
==============================================================================
--- activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java
(original)
+++ activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java
Thu Jul 23 12:58:53 2009
@@ -247,15 +247,15 @@
     public void stop() throws InterruptedException {
         synchronized (shutdownMutex) {
             if (!running)
-            return;
-        running = false;
+                return;
+            running = false;
             LOG.info("Stopping");
             // wake up pausing reconnect attempt
             shutdownMutex.notifyAll();
-        serverSessionPool.close();
+            serverSessionPool.close();
+        }
         disconnect();
     }
-    }
 
     private boolean isRunning() {
         return running;



Mime
View raw message