[hornetq-commits] JBoss hornetq SVN: r8141 - trunk/tests/src/org/hornetq/tests/integration/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-10-23 18:31:39 -0400 (Fri, 23 Oct 2009)
New Revision: 8141

Modified:
   trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java
Log:
This test was supposed to use asynchronous on the SessionFactory

Modified: trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java	2009-10-23 15:33:51 UTC (rev 8140)
+++ trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java	2009-10-23 22:31:39 UTC (rev 8141)
@@ -130,6 +130,8 @@
    private void addEmptyTransaction(Xid xid) throws HornetQException, XAException
    {
       ClientSessionFactory sf = createInVMFactory();
+      sf.setBlockOnNonPersistentSend(false);
+      sf.setBlockOnAcknowledge(false);
       ClientSession session = sf.createSession(true, false, false);
       session.start(xid, XAResource.TMNOFLAGS);
       session.end(xid, XAResource.TMSUCCESS);
@@ -141,6 +143,8 @@
    private void checkEmptyXID(Xid xid) throws HornetQException, XAException
    {
       ClientSessionFactory sf = createInVMFactory();
+      sf.setBlockOnNonPersistentSend(false);
+      sf.setBlockOnAcknowledge(false);
       ClientSession session = sf.createSession(true, false, false);
 
       Xid[] xids = session.recover(XAResource.TMSTARTRSCAN);
@@ -343,7 +347,9 @@
       server.start();
 
       sf = createNettyFactory();
-
+      sf.setBlockOnPersistentSend(false);
+      sf.setBlockOnAcknowledge(false);
+      
       ClientSession sess = sf.createSession();
 
       try