svn commit: r1406355 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

[tabish]

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);