activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r438840 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Thu, 31 Aug 2006 08:30:51 GMT
Author: rajdavies
Date: Thu Aug 31 01:30:50 2006
New Revision: 438840

URL: http://svn.apache.org/viewvc?rev=438840&view=rev
Log:
added debug around transport being disposed

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=438840&r1=438839&r2=438840&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
Thu Aug 31 01:30:50 2006
@@ -50,6 +50,7 @@
 import org.apache.activemq.transport.FutureResponse;
 import org.apache.activemq.transport.ResponseCallback;
 import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportDisposedIOException;
 import org.apache.activemq.transport.TransportListener;
 import org.apache.activemq.util.IdGenerator;
 import org.apache.activemq.util.LongSequenceGenerator;
@@ -143,7 +144,10 @@
 	                    synchronized( DemandForwardingBridgeSupport.this ) {
 		                    try{
 		                        localBroker.oneway(localConnectionInfo.createRemoveCommand());
-		                    }catch(IOException e){
+		                    }catch(TransportDisposedIOException td){
+                                log.debug("local broker is now disposed",td);
+                            }
+                            catch(IOException e){
 		                        log.warn("Caught exception from local start",e);
 		                    }
 	                    }



Mime
View raw message