Author: clebert.suconic(a)jboss.com Date: 2011-01-01 15:54:50 -0500 (Sat, 01 Jan 2011) New Revision: 10095 Modified: trunk/tests/src/org/hornetq/tests/stress/journal/LargeJournalStressTest.java Log: fixing stress test Modified: trunk/tests/src/org/hornetq/tests/stress/journal/LargeJournalStressTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/stress/journal/LargeJournalStressTest.java 2011-01-01 20:51:06 UTC (rev 10094) +++ trunk/tests/src/org/hornetq/tests/stress/journal/LargeJournalStressTest.java 2011-01-01 20:54:50 UTC (rev 10095) @@ -257,6 +257,11 @@ clearData(); locator = createInVMNonHALocator(); + + locator.setBlockOnAcknowledge(false); + locator.setBlockOnNonDurableSend(false); + locator.setBlockOnDurableSend(false); + } /** @@ -279,9 +284,6 @@ server.start(); sf = locator.createSessionFactory(); - sf.getServerLocator().setBlockOnAcknowledge(false); - sf.getServerLocator().setBlockOnNonDurableSend(false); - sf.getServerLocator().setBlockOnDurableSend(false); ClientSession sess = sf.createSession();