Author: clebert.suconic(a)jboss.com Date: 2010-08-13 01:54:20 -0400 (Fri, 13 Aug 2010) New Revision: 9539 Modified: trunk/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java Log: Improvements on test Modified: trunk/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java 2010-08-13 05:48:44 UTC (rev 9538) +++ trunk/tests/src/org/hornetq/tests/stress/journal/JournalCleanupCompactStressTest.java 2010-08-13 05:54:20 UTC (rev 9539) @@ -25,8 +25,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; -import javax.swing.plaf.basic.BasicInternalFrameTitlePane.MoveAction; - import org.hornetq.core.asyncio.impl.AsynchronousFileImpl; import org.hornetq.core.config.impl.ConfigurationImpl; import org.hornetq.core.journal.IOAsyncTask; @@ -317,16 +315,26 @@ long txID = JournalCleanupCompactStressTest.idGen.generateID(); + long rollbackTXID = JournalCleanupCompactStressTest.idGen.generateID(); + final long ids[] = new long[txSize]; + + for (int i = 0; i < txSize; i++) + { + ids[i] = JournalCleanupCompactStressTest.idGen.generateID(); + } + journal.appendAddRecordTransactional(rollbackTXID, ids[0], (byte)0, generateRecord()); + journal.appendRollbackRecord(rollbackTXID, true); + for (int i = 0; i < txSize; i++) { - long id = JournalCleanupCompactStressTest.idGen.generateID(); - ids[i] = id; + long id = ids[i]; journal.appendAddRecordTransactional(txID, id, (byte)0, generateRecord()); maxRecords.acquire(); } journal.appendCommitRecord(txID, true, ctx); + ctx.executeOnCompletion(new IOAsyncTask() {