[hornetq-commits] JBoss hornetq SVN: r9545 - trunk/src/main/org/hornetq/core/journal/impl.
Author: clebert.suconic(a)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");