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