svn commit: r438840 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

[rajdavies]

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);
                                    }
                            }