You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/11/06 22:49:49 UTC
svn commit: r1406355 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Author: tabish
Date: Tue Nov 6 21:49:48 2012
New Revision: 1406355
URL: http://svn.apache.org/viewvc?rev=1406355&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQ-3016
Don't count-down the shutdown latch early.
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?rev=1406355&r1=1406354&r2=1406355&view=diff
==============================================================================
--- 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 Nov 6 21:49:48 2012
@@ -356,7 +356,6 @@ public abstract class DemandForwardingBr
public void run() {
try {
localBroker.oneway(new ShutdownInfo());
- sendShutdown.countDown();
remoteBroker.oneway(new ShutdownInfo());
} catch (Throwable e) {
LOG.debug("Caught exception sending shutdown", e);