[hornetq-commits] JBoss hornetq SVN: r9545 - trunk/src/main/org/hornetq/core/journal/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-08-13 11:15:31 -0400 (Fri, 13 Aug 2010)
New Revision: 9545

Modified:
   trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java
Log:
tweak

Modified: trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2010-08-13 15:11:42 UTC (rev 9544)
+++ trunk/src/main/org/hornetq/core/journal/impl/JournalImpl.java	2010-08-13 15:15:31 UTC (rev 9545)
@@ -1660,6 +1660,11 @@
 
             // Replay pending commands (including updates, deletes and commits)
 
+            for (JournalTransaction newTransaction : localCompactor.getNewTransactions().values())
+            {
+               newTransaction.replaceRecordProvider(this);
+            }
+            
             localCompactor.replayPendingCommands();
 
             // Merge transactions back after compacting
@@ -1668,8 +1673,6 @@
 
             for (JournalTransaction newTransaction : localCompactor.getNewTransactions().values())
             {
-               newTransaction.replaceRecordProvider(this);
-               
                if (JournalImpl.trace)
                {
                   JournalImpl.trace("Merging pending transaction " + newTransaction + " after compacting the journal");