[hornetq-commits] JBoss hornetq SVN: r9583 - branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-08-24 04:22:54 -0400 (Tue, 24 Aug 2010)
New Revision: 9583

Modified:
   branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java
Log:
fix PersistentDivertTest

Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java
===================================================================
--- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java	2010-08-23 15:57:26 UTC (rev 9582)
+++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/divert/PersistentDivertTest.java	2010-08-24 08:22:54 UTC (rev 9583)
@@ -106,12 +106,12 @@
 
       ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
 
+      locator.setBlockOnAcknowledge(true);
+      locator.setBlockOnNonDurableSend(true);
+      locator.setBlockOnDurableSend(true);
+
       ClientSessionFactory sf = locator.createSessionFactory();
 
-      sf.getServerLocator().setBlockOnAcknowledge(true);
-      sf.getServerLocator().setBlockOnNonDurableSend(true);
-      sf.getServerLocator().setBlockOnDurableSend(true);
-
       ClientSession session = sf.createSession(true, true, 0);
 
       final SimpleString queueName1 = new SimpleString("queue1");
@@ -310,12 +310,12 @@
       messagingService.start();
 
       ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+      locator.setBlockOnAcknowledge(true);
+      locator.setBlockOnNonDurableSend(true);
+      locator.setBlockOnDurableSend(true);
+
       ClientSessionFactory sf = locator.createSessionFactory();
 
-      sf.getServerLocator().setBlockOnAcknowledge(true);
-      sf.getServerLocator().setBlockOnNonDurableSend(true);
-      sf.getServerLocator().setBlockOnDurableSend(true);
-
       ClientSession session = sf.createSession(true, true, 0);
 
       final SimpleString queueName1 = new SimpleString("queue1");
@@ -363,10 +363,9 @@
       messagingService.start();
 
       ServerLocator locator2 = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
-      sf = locator2.createSessionFactory();
+      locator2.setBlockOnDurableSend(true);
 
-      sf.getServerLocator().setBlockOnDurableSend(true);
-
+      sf = locator2.createSessionFactory();
       session = sf.createSession(false, true, true);
 
       session.start();
@@ -460,11 +459,10 @@
       messagingService.start();
 
       ServerLocator locator3 = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+      locator3.setBlockOnDurableSend(true);
 
       sf = locator3.createSessionFactory();
 
-      sf.getServerLocator().setBlockOnDurableSend(true);
-
       session = sf.createSession(false, true, true);
 
       consumer1 = session.createConsumer(queueName1);