Author: clebert.suconic(a)jboss.com Date: 2011-08-04 23:13:03 -0400 (Thu, 04 Aug 2011) New Revision: 11129 Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java Log: tweak 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-08-05 02:36:17 UTC (rev 11128) +++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java 2011-08-05 03:13:03 UTC (rev 11129) @@ -1510,6 +1510,16 @@ private synchronized void createConnectors() { + if (connectors != null) + { + for (Connector conn : connectors) + { + if (conn != null) + { + conn.disconnect(); + } + } + } connectors = new ArrayList<Connector>(); for (TransportConfiguration initialConnector : initialConnectors) { @@ -1605,7 +1615,7 @@ if (factory != null) { factory.causeExit(); - factory.close(); + factory.cleanup(); factory = null; } }