[hornetq-commits] JBoss hornetq SVN: r11129 - 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-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;
             }
          }