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

[do-not-reply at jboss.org]

Author: timfox
Date: 2009-12-06 06:34:53 -0500 (Sun, 06 Dec 2009)
New Revision: 8588

Modified:
   trunk/tests/src/org/hornetq/tests/integration/journal/ValidateTransactionHealthTest.java
Log:
Fixed TransactionHealthTest

Modified: trunk/tests/src/org/hornetq/tests/integration/journal/ValidateTransactionHealthTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/journal/ValidateTransactionHealthTest.java	2009-12-06 08:17:19 UTC (rev 8587)
+++ trunk/tests/src/org/hornetq/tests/integration/journal/ValidateTransactionHealthTest.java	2009-12-06 11:34:53 UTC (rev 8588)
@@ -20,6 +20,7 @@
 
 import org.hornetq.core.asyncio.impl.AsynchronousFileImpl;
 import org.hornetq.core.config.impl.ConfigurationImpl;
+import org.hornetq.core.journal.Journal;
 import org.hornetq.core.journal.LoaderCallback;
 import org.hornetq.core.journal.PreparedTransactionInfo;
 import org.hornetq.core.journal.RecordInfo;
@@ -27,6 +28,7 @@
 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.logging.Logger;
 import org.hornetq.tests.util.SpawnedVMSupport;
 import org.hornetq.tests.util.UnitTestCase;
 
@@ -42,6 +44,9 @@
 
    // Constants -----------------------------------------------------
 
+   private static final Logger log = Logger.getLogger(ValidateTransactionHealthTest.class);
+
+   
    // Attributes ----------------------------------------------------
 
    private static final int OK = 10;
@@ -114,8 +119,6 @@
       internalTest("nio2", getTestDir(), 10000, 0, true, true, 1);
    }
 
-
-
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------
@@ -297,7 +300,9 @@
 
       try
       {
-         appendData(journalType, journalDir, numberOfElements, transactionSize, numberOfThreads);
+         Journal journal = appendData(journalType, journalDir, numberOfElements, transactionSize, numberOfThreads);
+         
+         journal.stop();
 
       }
       catch (Exception e)
@@ -342,17 +347,17 @@
          }
       });
 
-      LocalThreads threads[] = new LocalThreads[numberOfThreads];
+      LocalThread threads[] = new LocalThread[numberOfThreads];
       final AtomicLong sequenceTransaction = new AtomicLong();
 
       for (int i = 0; i < numberOfThreads; i++)
       {
-         threads[i] = new LocalThreads(journal, numberOfElements, transactionSize, sequenceTransaction);
+         threads[i] = new LocalThread(journal, numberOfElements, transactionSize, sequenceTransaction);
          threads[i].start();
       }
 
       Exception e = null;
-      for (LocalThreads t : threads)
+      for (LocalThread t : threads)
       {
          t.join();
 
@@ -403,7 +408,7 @@
       }
    }
 
-   static class LocalThreads extends Thread
+   static class LocalThread extends Thread
    {
       final JournalImpl journal;
 
@@ -415,7 +420,7 @@
 
       Exception e;
 
-      public LocalThreads(JournalImpl journal, long numberOfElements, int transactionSize, AtomicLong nextID)
+      public LocalThread(JournalImpl journal, long numberOfElements, int transactionSize, AtomicLong nextID)
       {
          super();
          this.journal = journal;