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

[do-not-reply at jboss.org]

Author: borges
Date: 2011-10-26 06:48:55 -0400 (Wed, 26 Oct 2011)
New Revision: 11601

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
Log:
Fix incorrect check for isClosed()

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-10-26 10:25:21 UTC (rev 11600)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-10-26 10:48:55 UTC (rev 11601)
@@ -747,7 +747,7 @@
 
             }
 
-            if (System.currentTimeMillis() > timeout && !receivedTopology && !isClosed())
+            if (System.currentTimeMillis() > timeout && !receivedTopology)
             {
                throw new HornetQException(HornetQException.CONNECTION_TIMEDOUT,
                                           "Timed out waiting to receive cluster topology. Group:" + discoveryGroup);
@@ -1486,7 +1486,6 @@
 
       if (isClosed())
       {
-         factory.causeExit();
          factory.close();
          return;
       }