You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2006/12/30 08:27:08 UTC
svn commit: r491185 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Author: rajdavies
Date: Fri Dec 29 23:27:06 2006
New Revision: 491185
URL: http://svn.apache.org/viewvc?view=rev&rev=491185
Log:
Applied patch from: https://issues.apache.org/activemq/browse/AMQ-961
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?view=diff&rev=491185&r1=491184&r2=491185
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java Fri Dec 29 23:27:06 2006
@@ -176,8 +176,15 @@
}
}
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 );
+ }
+
}
}
});