[hornetq-commits] JBoss hornetq SVN: r10987 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-07-14 14:39:50 -0400 (Thu, 14 Jul 2011)
New Revision: 10987

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
Log:
Fixing test

Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-07-14 17:09:28 UTC (rev 10986)
+++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-07-14 18:39:50 UTC (rev 10987)
@@ -1363,8 +1363,10 @@
          try
          {
             
+            int retryNumber = 0;
             while (csf == null && !ServerLocatorImpl.this.closed && !ServerLocatorImpl.this.closing)
             {
+               retryNumber ++;
                for (Connector conn : connectors)
                {
                    if (log.isDebugEnabled())
@@ -1380,6 +1382,11 @@
                    }
                }
                
+               if (initialConnectAttempts >=0 && retryNumber > initialConnectAttempts)
+               {
+                  break;
+               }
+               
                Thread.sleep (retryInterval);
             }