activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r559139 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Tue, 24 Jul 2007 17:51:33 GMT
Author: chirino
Date: Tue Jul 24 10:51:32 2007
New Revision: 559139

URL: http://svn.apache.org/viewvc?view=rev&rev=559139
Log:
Fix for AMQ-1343 - Network conntions not shutdown propertly when a InvalidClientIDException
occurs

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?view=diff&rev=559139&r1=559138&r2=559139
==============================================================================
--- 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
Tue Jul 24 10:51:32 2007
@@ -335,6 +335,11 @@
                 ServiceStopper ss=new ServiceStopper();
                 ss.stop(localBroker);
                 ss.stop(remoteBroker);
+                
+				// Release the started Latch since another thread could be stuck waiting for it to start
up.
+				startedLatch.countDown();
+				startedLatch.countDown();
+
                 ss.throwFirstException();
             }
         }



Mime
View raw message