[hornetq-commits] JBoss hornetq SVN: r11058 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl.
Author: clebert.suconic(a)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)
{