activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1475842 - /activemq/trunk/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
Date Thu, 25 Apr 2013 16:25:51 GMT
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();
         }



Mime
View raw message