activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1086210 - /activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java
Date Mon, 28 Mar 2011 12:36:05 GMT
Author: gtully
Date: Mon Mar 28 12:36:05 2011
New Revision: 1086210

URL: http://svn.apache.org/viewvc?rev=1086210&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-2662 - ActiveMQEndpointWorker.stop() sometimes is
needing many minutes to shutdown; patch applied with thanks

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=1086210&r1=1086209&r2=1086210&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
Mon Mar 28 12:36:05 2011
@@ -70,7 +70,7 @@ public class ActiveMQEndpointWorker {
     private final ActiveMQDestination dest;
     private final Work connectWork;
     private final AtomicBoolean connecting = new AtomicBoolean(false);    
-    private final String shutdownMutex = "shutdownMutex";
+    private final Object shutdownMutex = new String("shutdownMutex");
     
     private ActiveMQConnection connection;
     private ConnectionConsumer consumer;



Mime
View raw message