From 395bf82f80a5b8ba7adbd1d5dcdc0c3db8d34363 Mon Sep 17 00:00:00 2001
From: Gary Tully <gtully@apache.org>
Date: Mon, 28 Nov 2011 23:20:07 +0000
Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-2868 - fix issue
 with blocked transaction completion in highly concurrent systems. It was
 possible to miss an after completion callback

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207693 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/activemq/store/kahadb/MessageDatabase.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
index 87634e9aee..365c509a22 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
@@ -1061,6 +1061,10 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
             }
         }
         if (inflightTx == null) {
+            if (after != null) {
+                // since we don't push this after and we may find another, lets run it now
+                after.run();
+            }
             return;
         }