activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1087051 - /activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
Date Wed, 30 Mar 2011 19:26:59 GMT
Author: tabish
Date: Wed Mar 30 19:26:59 2011
New Revision: 1087051

URL: http://svn.apache.org/viewvc?rev=1087051&view=rev
Log:
fix for https://issues.apache.org/jira/browse/AMQCPP-358 on 3.2.x fixes branch.

Modified:
    activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp

Modified: activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp?rev=1087051&r1=1087050&r2=1087051&view=diff
==============================================================================
--- activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
(original)
+++ activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
Wed Mar 30 19:26:59 2011
@@ -501,7 +501,9 @@ bool FailoverTransport::isPending() cons
                 reconnectAttempts = maxReconnectAttempts;
             }
 
-            if( reconnectAttempts > 0 && connectFailures < reconnectAttempts
) {
+            if( reconnectAttempts > 0 && connectFailures >= reconnectAttempts
) {
+                result = false;
+            } else {
                 result = true;
             }
         }



Mime
View raw message