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