activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1186654 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Date Thu, 20 Oct 2011 07:59:05 GMT
Author: gtully
Date: Thu Oct 20 07:59:05 2011
New Revision: 1186654

URL: http://svn.apache.org/viewvc?rev=1186654&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3542 - prevent failover reconnect till start is
initiated, prevents connection establishment w/o a listener which ensures a bridge is already
ready to handle a response and start a local bridge, useDedicatedTaskRunner=true can lead
to this case

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

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=1186654&r1=1186653&r2=1186654&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Thu Oct 20 07:59:05 2011
@@ -124,6 +124,9 @@ public class FailoverTransport implement
         reconnectTask = DefaultThreadPools.getDefaultTaskRunnerFactory().createTaskRunner(new
Task() {
             public boolean iterate() {
                 boolean result = false;
+                if (!started) {
+                    return result;
+                }
                 boolean buildBackup = true;
                 synchronized (backupMutex) {
                     if ((connectedTransport.get() == null || doRebalance) && !disposed)
{



Mime
View raw message