activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r929145 - in /activemq/trunk: activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQXAManagedConnectionFactory.java
Date Tue, 30 Mar 2010 14:02:41 GMT
Author: gtully
Date: Tue Mar 30 14:02:40 2010
New Revision: 929145

URL: http://svn.apache.org/viewvc?rev=929145&view=rev
Log:
resolve https://issues.apache.org/activemq/browse/AMQ-2670 - revert XA connection manager,
using out of band recovery via JMS api is a workaround for jboss pending RAR based auto recovery
or enlistment, comments in the jira with the relevant config

Removed:
    activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQXAManagedConnectionFactory.java
Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java?rev=929145&r1=929144&r2=929145&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java
Tue Mar 30 14:02:40 2010
@@ -128,12 +128,18 @@ public class TransactionBroker extends B
             for (Iterator<Transaction> iter = xaTransactions.values().iterator(); iter.hasNext();)
{
                 Transaction tx = iter.next();
                 if (tx.isPrepared()) {
+                    if (LOG.isDebugEnabled()) {
+                        LOG.debug("prepared transaction: " + tx.getTransactionId());
+                    }
                     txs.add(tx.getTransactionId());
                 }
             }
         }
         XATransactionId rc[] = new XATransactionId[txs.size()];
         txs.toArray(rc);
+        if (LOG.isDebugEnabled()) {
+            LOG.debug("prepared transacton list size: " + rc.length);
+        }
         return rc;
     }
 



Mime
View raw message