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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-04-04 12:29:19 -0400 (Mon, 04 Apr 2011)
New Revision: 10442

Modified:
   trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
Log:
Fixing test

Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2011-04-04 04:04:09 UTC (rev 10441)
+++ trunk/src/main/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java	2011-04-04 16:29:19 UTC (rev 10442)
@@ -713,6 +713,11 @@
    public void commit(final long txID, final boolean lineUpContext) throws Exception
    {
       messageJournal.appendCommitRecord(txID, syncTransactional, getContext(syncTransactional), lineUpContext);
+      if (!lineUpContext && !syncTransactional)
+      {
+         // if lineUpContext == false, we have previously lined up a context, hence we need to mark it as done even if syncTransactional = false
+         getContext(true).done();
+      }
    }
 
    public void rollback(final long txID) throws Exception