Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-06 01:59:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Applied patch from: https://issues.apache.org/activemq/browse/AMQ-961

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491185 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2006-12-30 07:27:06 +00:00
parent 7351c4bd0d
commit 2a682e2fb2
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
View File

@ -176,8 +176,15 @@ public abstract class DemandForwardingBridgeSupport implements Bridge {
}
}
lastConnectSucceeded.set(false);
log.debug("Outbound transport to " + remoteBrokerName + " resumed");
try {
startLocalBridge();
remoteBridgeStarted.set(true);
startedLatch.countDown();
log.debug("Outbound transport to " + remoteBrokerName + " resumed");
}catch(Exception e) {
log.error("Caught exception from local start ib resume transport",e );
}
}
}
});