You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2007/07/24 19:51:33 UTC
svn commit: r559139 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
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();
}
}