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()