Author: clebert.suconic(a)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); }