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

Monday, 29 August 2011


Author: clebert.suconic(a)jboss.com
Date: 2011-08-29 15:49:15 -0400 (Mon, 29 Aug 2011)
New Revision: 11235

Modified:
  
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
Log:
test for my branch only

Modified:
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java
===================================================================
---
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-08-29
16:20:36 UTC (rev 11234)
+++
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-08-29
19:49:15 UTC (rev 11235)
@@ -528,6 +528,24 @@
       initialise();
 
       this.startExecutor = executor;
+
+      executor.execute(new Runnable()
+      {
+         public void run()
+         {
+            try
+            {
+               connect();
+            }
+            catch (Exception e)
+            {
+               if (!closing)
+               {
+                  log.warn("did not connect the cluster connection to other
nodes", e);
+               }
+            }
+         }
+      });
    }
    
    public Executor getExecutor()


    