[hornetq-commits] JBoss hornetq SVN: r10095 - trunk/tests/src/org/hornetq/tests/stress/journal.
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();