[hornetq-commits] JBoss hornetq SVN: r9539 - trunk/tests/src/org/hornetq/tests/stress/journal.

[do-not-reply at jboss.org]

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