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