svn commit: r1086210 - /activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java

[gtully]

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;