[hornetq-commits] JBoss hornetq SVN: r10098 - trunk/tests/src/org/hornetq/tests/stress/paging.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-01-01 18:52:51 -0500 (Sat, 01 Jan 2011)
New Revision: 10098

Modified:
   trunk/tests/src/org/hornetq/tests/stress/paging/PageStressTest.java
Log:
fixing test

Modified: trunk/tests/src/org/hornetq/tests/stress/paging/PageStressTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/stress/paging/PageStressTest.java	2011-01-01 22:07:31 UTC (rev 10097)
+++ trunk/tests/src/org/hornetq/tests/stress/paging/PageStressTest.java	2011-01-01 23:52:51 UTC (rev 10098)
@@ -19,7 +19,12 @@
 
 import org.hornetq.api.core.HornetQException;
 import org.hornetq.api.core.SimpleString;
-import org.hornetq.api.core.client.*;
+import org.hornetq.api.core.client.ClientConsumer;
+import org.hornetq.api.core.client.ClientMessage;
+import org.hornetq.api.core.client.ClientProducer;
+import org.hornetq.api.core.client.ClientSession;
+import org.hornetq.api.core.client.ClientSessionFactory;
+import org.hornetq.api.core.client.ServerLocator;
 import org.hornetq.core.config.Configuration;
 import org.hornetq.core.server.HornetQServer;
 import org.hornetq.core.settings.impl.AddressSettings;
@@ -64,9 +69,6 @@
       messagingService.start();
 
       ClientSessionFactory factory = locator.createSessionFactory();
-      factory.getServerLocator().setBlockOnAcknowledge(true);
-      factory.getServerLocator().setBlockOnDurableSend(false);
-      factory.getServerLocator().setBlockOnNonDurableSend(false);
       ClientSession session = null;
 
       try
@@ -303,6 +305,11 @@
       clearData();
 
       locator = createInVMNonHALocator();
+      
+      locator.setBlockOnAcknowledge(true);
+      locator.setBlockOnDurableSend(false);
+      locator.setBlockOnNonDurableSend(false);
+
    }
 
    @Override