Author: chirino
Date: Thu Jul 6 17:51:25 2006
New Revision: 419752
URL: http://svn.apache.org/viewvc?rev=419752&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-799
Modified:
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Modified:
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=419752&r1=419751&r2=419752&view=diff
==============================================================================
---
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
(original)
+++
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Thu Jul 6 17:51:25 2006
@@ -25,6 +25,7 @@
import org.apache.activemq.command.BrokerId;
import org.apache.activemq.command.BrokerInfo;
import org.apache.activemq.command.Command;
+import org.apache.activemq.command.ConnectionError;
import org.apache.activemq.command.ConnectionId;
import org.apache.activemq.command.ConnectionInfo;
import org.apache.activemq.command.ConsumerId;
@@ -317,7 +318,7 @@
}
}
- protected void serviceRemoteException(Exception error) {
+ protected void serviceRemoteException(Throwable error) {
log.info("Network connection between "+localBroker+" and
"+remoteBroker+" shutdown: "+error.getMessage(),error);
ServiceSupport.dispose(this);
}
@@ -336,6 +337,9 @@
}
}else if(command.isBrokerInfo()){
serviceRemoteBrokerInfo(command);
+ }else if(command.getClass() == ConnectionError.class ) {
+ ConnectionError ce = (ConnectionError) command;
+ serviceRemoteException(ce.getException());
}else{
switch(command.getDataStructureType()){
case KeepAliveInfo.DATA_STRUCTURE_TYPE:
@@ -520,7 +524,9 @@
shutDown = true;
doStop();
}
-
+ }else if(command.getClass() == ConnectionError.class ) {
+ ConnectionError ce = (ConnectionError) command;
+ serviceLocalException(ce.getException());
}else{
switch(command.getDataStructureType()){
case WireFormatInfo.DATA_STRUCTURE_TYPE:
