activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r386076 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Date Wed, 15 Mar 2006 14:14:31 GMT
Author: jstrachan
Date: Wed Mar 15 06:14:29 2006
New Revision: 386076

URL: http://svn.apache.org/viewcvs?rev=386076&view=rev
Log:
catch interupted exceptions

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=386076&r1=386075&r2=386076&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Wed Mar 15 06:14:29 2006
@@ -322,7 +322,12 @@
                         // Wait for transport to be connected.
                         while (connectedTransport == null && !disposed &&
connectionFailure==null ) {
                             log.debug("Waiting for transport to reconnect.");
-                            reconnectMutex.wait(1000);
+                            try {
+                                reconnectMutex.wait(1000);
+                            }
+                            catch (InterruptedException e) {
+                                log.debug("Interupted: " + e, e);
+                            }
                         }
 
                         if( connectedTransport==null ) {



Mime
View raw message