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

Author: clebert.suconic(a)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