svn commit: r1475842 - /activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java

[tabish]

Author: tabish
Date: Thu Apr 25 16:25:51 2013
New Revision: 1475842

URL: http://svn.apache.org/r1475842
Log:
Fix for: https://issues.apache.org/jira/browse/AMQ-4488

Modified:
    
activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java

Modified: 
activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java?rev=1475842&r1=1475841&r2=1475842&view=diff
==============================================================================
--- 
activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
 (original)
+++ 
activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
 Thu Apr 25 16:25:51 2013
@@ -610,6 +610,13 @@ public abstract class MessageDatabase ex
                     store(new 
KahaRollbackCommand().setTransactionInfo(TransactionIdConversion.convertToLocal(tx)),
 false, null, null);
                 }
             }
+
+            synchronized (preparedTransactions) {
+                for (TransactionId txId : preparedTransactions.keySet()) {
+                    LOG.warn("Recovered prepared XA TX: [{}]", txId);
+                }
+            }
+
         } finally {
             this.indexLock.writeLock().unlock();
         }