diff --git a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java index 97c24b6989..7551a464d3 100644 --- a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java +++ b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java @@ -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 ); + } + } } });