mirror of https://github.com/apache/activemq.git
Fix for AMQ-1343 - Network conntions not shutdown propertly when a InvalidClientIDException occurs
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559139 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
7c94a73ba6
commit
76b2a3ed8f
|
@ -335,6 +335,11 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge {
|
||||||
ServiceStopper ss=new ServiceStopper();
|
ServiceStopper ss=new ServiceStopper();
|
||||||
ss.stop(localBroker);
|
ss.stop(localBroker);
|
||||||
ss.stop(remoteBroker);
|
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();
|
ss.throwFirstException();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue