[hornetq-commits] JBoss hornetq SVN: r10095 - trunk/tests/src/org/hornetq/tests/stress/journal.

[do-not-reply at jboss.org]

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