[hornetq-commits] JBoss hornetq SVN: r11058 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-07-27 16:02:45 -0400 (Wed, 27 Jul 2011)
New Revision: 11058

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
Log:
fixing test

Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2011-07-27 17:29:18 UTC (rev 11057)
+++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2011-07-27 20:02:45 UTC (rev 11058)
@@ -31,6 +31,7 @@
 import org.hornetq.api.core.SimpleString;
 import org.hornetq.api.core.TransportConfiguration;
 import org.hornetq.api.core.client.ClientMessage;
+import org.hornetq.api.core.client.ClusterTopologyListener;
 import org.hornetq.api.core.client.HornetQClient;
 import org.hornetq.api.core.client.ServerLocator;
 import org.hornetq.api.core.management.ManagementHelper;
@@ -652,8 +653,10 @@
       targetLocator.setRetryIntervalMultiplier(retryIntervalMultiplier);
       
       targetLocator.setNodeID(serverLocator.getNodeID());
+
+      targetLocator.setClusterTransportConfiguration(serverLocator.getClusterTransportConfiguration());
       
-      targetLocator.setClusterTransportConfiguration(serverLocator.getClusterTransportConfiguration());
+      targetLocator.addClusterTopologyListener(this);
 
       if(retryInterval > 0)
       {