You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/06/12 17:17:31 UTC
svn commit: r413679 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Author: chirino
Date: Mon Jun 12 08:17:30 2006
New Revision: 413679
URL: http://svn.apache.org/viewvc?rev=413679&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-734
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?rev=413679&r1=413678&r2=413679&view=diff
==============================================================================
--- 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 Mon Jun 12 08:17:30 2006
@@ -135,7 +135,7 @@
log.warn("Outbound transport to " + remoteBrokerName + " interrupted ...");
clearDownSubscriptions();
try{
- localBroker.oneway(remoteConnectionInfo.createRemoveCommand());
+ localBroker.oneway(localConnectionInfo.createRemoveCommand());
}catch(IOException e){
log.warn("Caught exception from local start",e);
}