activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r378969 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Date Sun, 19 Feb 2006 22:15:44 GMT
Author: rajdavies
Date: Sun Feb 19 14:15:43 2006
New Revision: 378969

URL: http://svn.apache.org/viewcvs?rev=378969&view=rev
Log:
don't iterate forever in oneWay() if disposed (can cause some tests to hang in Connection
close)

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=378969&r1=378968&r2=378969&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
Sun Feb 19 14:15:43 2006
@@ -305,7 +305,7 @@
 
             synchronized (reconnectMutex) {
                 // Keep trying until the message is sent.
-                for (int i = 0;; i++) {
+                for (int i = 0;!disposed; i++) {
                     try {
 
                         // Wait for transport to be connected.



Mime
View raw message