Author: clebert.suconic(a)jboss.com Date: 2011-09-19 17:54:41 -0400 (Mon, 19 Sep 2011) New Revision: 11369 Modified: branches/Branch_2_2_EAP_cluster4/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java Log: fixing tests Modified: branches/Branch_2_2_EAP_cluster4/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java =================================================================== --- branches/Branch_2_2_EAP_cluster4/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-09-19 15:34:05 UTC (rev 11368) +++ branches/Branch_2_2_EAP_cluster4/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-09-19 21:54:41 UTC (rev 11369) @@ -1554,7 +1554,7 @@ { log.debug(ClusterConnectionImpl.this + "Creating a serverLocator for " + Arrays.toString(tcConfigs)); } - ServerLocatorImpl locator = new ServerLocatorImpl(topology, true, tcConfigs); + ServerLocatorImpl locator = new ServerLocatorImpl(includeTopology?topology:null, true, tcConfigs); locator.setClusterConnection(true); return locator; } @@ -1586,7 +1586,7 @@ public ServerLocatorInternal createServerLocator(boolean includeTopology) { - ServerLocatorImpl locator = new ServerLocatorImpl(topology, true, dg); + ServerLocatorImpl locator = new ServerLocatorImpl(includeTopology?topology:null, true, dg); return locator; }