[hornetq-commits] JBoss hornetq SVN: r10093 - 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:40:36 -0500 (Sat, 01 Jan 2011)
New Revision: 10093

Modified:
   trunk/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java
Log:
fixing stress test

Modified: trunk/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java	2011-01-01 20:25:59 UTC (rev 10092)
+++ trunk/tests/src/org/hornetq/tests/stress/journal/NIOMultiThreadCompactorStressTest.java	2011-01-01 20:40:36 UTC (rev 10093)
@@ -72,6 +72,9 @@
       super.setUp();
 
       locator = createInVMNonHALocator();
+      locator.setBlockOnNonDurableSend(false);
+      locator.setBlockOnAcknowledge(false);
+
    }
 
    @Override
@@ -153,8 +156,6 @@
    private void addEmptyTransaction(final Xid xid) throws Exception, XAException
    {
       ClientSessionFactory sf = locator.createSessionFactory();
-      sf.getServerLocator().setBlockOnNonDurableSend(false);
-      sf.getServerLocator().setBlockOnAcknowledge(false);
       ClientSession session = sf.createSession(true, false, false);
       session.start(xid, XAResource.TMNOFLAGS);
       session.end(xid, XAResource.TMSUCCESS);
@@ -166,8 +167,6 @@
    private void checkEmptyXID(final Xid xid) throws Exception, XAException
    {
       ClientSessionFactory sf = locator.createSessionFactory();
-      sf.getServerLocator().setBlockOnNonDurableSend(false);
-      sf.getServerLocator().setBlockOnAcknowledge(false);
       ClientSession session = sf.createSession(true, false, false);
 
       Xid[] xids = session.recover(XAResource.TMSTARTRSCAN);
@@ -377,10 +376,10 @@
       server.start();
 
       ServerLocator locator = createNettyNonHALocator();
+      locator.setBlockOnDurableSend(false);
+      locator.setBlockOnAcknowledge(false);
 
       sf = locator.createSessionFactory();
-      sf.getServerLocator().setBlockOnDurableSend(false);
-      sf.getServerLocator().setBlockOnAcknowledge(false);
 
       ClientSession sess = sf.createSession();
 
@@ -393,10 +392,6 @@
       }
 
       sess.close();
-
-      locator.close();
-
-      sf = locator.createSessionFactory();
    }
 
    // Static --------------------------------------------------------