activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1406355 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Tue, 06 Nov 2012 21:49:49 GMT
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);



Mime
View raw message