mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1475842 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
f2b01a7f01
commit
7057e819eb
|
@ -610,6 +610,13 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
|
|||
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();
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue