[hornetq-commits] JBoss hornetq SVN: r9597 - branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-08-25 11:34:03 -0400 (Wed, 25 Aug 2010)
New Revision: 9597

Modified:
   branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
fix test setup

Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2010-08-25 09:06:02 UTC (rev 9596)
+++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2010-08-25 15:34:03 UTC (rev 9597)
@@ -1161,15 +1161,14 @@
 
 
       ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(serverTotc);
-      ClientSessionFactory sf = locator.createSessionFactory();
+      locator.setFailoverOnServerShutdown(false);
+      locator.setRetryInterval(100);
+      locator.setRetryIntervalMultiplier(1d);
+      locator.setReconnectAttempts(-1);
+      locator.setBlockOnNonDurableSend(blocking);
+      locator.setBlockOnDurableSend(blocking);
 
-      sf.getServerLocator().setFailoverOnServerShutdown(false);
-      sf.getServerLocator().setRetryInterval(100);
-      sf.getServerLocator().setRetryIntervalMultiplier(1d);
-      sf.getServerLocator().setReconnectAttempts(-1);
-      sf.getServerLocator().setBlockOnNonDurableSend(blocking);
-      sf.getServerLocator().setBlockOnDurableSend(blocking);
-
+      ClientSessionFactory sf = locator.createSessionFactory();
       sfs[node] = sf;
    }