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