svn commit: r1087051 - /activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp

[tabish]

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