Author: clebert.suconic(a)jboss.com Date: 2009-11-04 11:59:56 -0500 (Wed, 04 Nov 2009) New Revision: 8213 Modified: trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java Log: tweaks Modified: trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java 2009-11-04 16:57:35 UTC (rev 8212) +++ trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java 2009-11-04 16:59:56 UTC (rev 8213) @@ -33,7 +33,6 @@ import org.hornetq.core.exception.HornetQException; import org.hornetq.core.journal.PreparedTransactionInfo; import org.hornetq.core.journal.RecordInfo; -import org.hornetq.core.journal.impl.AIOSequentialFileFactory; import org.hornetq.core.journal.impl.JournalImpl; import org.hornetq.core.journal.impl.NIOSequentialFileFactory; import org.hornetq.core.server.HornetQServer; @@ -99,10 +98,10 @@ "hornetq-data", "hq", 100); - + List<RecordInfo> committedRecords = new ArrayList<RecordInfo>(); List<PreparedTransactionInfo> preparedTransactions = new ArrayList<PreparedTransactionInfo>(); - + journal.start(); journal.load(committedRecords, preparedTransactions, null); @@ -156,7 +155,7 @@ assertEquals(xid, xids[0]); session.rollback(xid); - + session.close(); sf.close(); } @@ -243,7 +242,7 @@ setupServer(JournalType.ASYNCIO); drainQueue(0, QUEUE); drainQueue(0, new SimpleString("LAZY-QUEUE")); - + checkEmptyXID(xid); } @@ -268,7 +267,7 @@ if (i % 100 == 0) { - System.out.println("Received #" + i + " on thread after start"); + // System.out.println("Received #" + i + " on thread after start"); } msg.acknowledge(); } @@ -345,11 +344,10 @@ config.setJournalCompactMinFiles(ConfigurationImpl.DEFAULT_JOURNAL_COMPACT_MIN_FILES); config.setJournalCompactPercentage(ConfigurationImpl.DEFAULT_JOURNAL_COMPACT_PERCENTAGE); - + // This test is supposed to not sync.. All the ACKs are async, and it was supposed to not sync config.setJournalSyncNonTransactional(false); - - + // config.setJournalCompactMinFiles(0); // config.setJournalCompactPercentage(0); @@ -361,7 +359,7 @@ sf = createNettyFactory(); sf.setBlockOnPersistentSend(false); sf.setBlockOnAcknowledge(false); - + ClientSession sess = sf.createSession(); try @@ -446,7 +444,7 @@ } if (i % 100 == 0) { - System.out.println(Thread.currentThread().getName() + "::sent #" + i); + // System.out.println(Thread.currentThread().getName() + "::sent #" + i); } ClientMessage msg = session.createClientMessage(true); msg.setBody(ChannelBuffers.wrappedBuffer(new byte[1024])); @@ -514,7 +512,7 @@ } if (i % 100 == 0) { - System.out.println(Thread.currentThread().getName() + "::received #" + i); + // System.out.println(Thread.currentThread().getName() + "::received #" + i); } }