diff --git a/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTransactionStore.java b/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTransactionStore.java index d42ff93ab4..9f192900a6 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTransactionStore.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTransactionStore.java @@ -237,13 +237,9 @@ public class MemoryTransactionStore implements TransactionStore { tx = inflightTransactions.remove(txid); } - if (tx == null) { - if (postCommit != null) { - postCommit.run(); - } - return; + if (tx != null) { + tx.commit(); } - tx.commit(); if (postCommit != null) { postCommit.run(); }