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

[do-not-reply at jboss.org]

Author: clebert.suconic at 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()