org.mule.util.journal.queue

Class LocalTxQueueTransactionRecoverer

java.lang.Object

org.mule.util.journal.queue.LocalTxQueueTransactionRecoverer

public class LocalTxQueueTransactionRecoverer
extends Object

Process for recover pending transactions after a server crash. This process must be executed before accessing the transactional queues.

Constructor Summary

Constructors

Constructor and Description
LocalTxQueueTransactionRecoverer(LocalTxQueueTransactionJournal localTxQueueTransactionJournal, QueueProvider queueProvider)

Method Summary

Methods

Modifier and Type	Method and Description
void	recover() Recover all the pending transactions.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalTxQueueTransactionRecoverer

public LocalTxQueueTransactionRecoverer(LocalTxQueueTransactionJournal localTxQueueTransactionJournal,
                                QueueProvider queueProvider)

Method Detail

recover

public void recover()

Recover all the pending transactions. Will undo all operations done over queues that were not commit or rolled back. Clears the transaction log after processing all the log entries since does entries are not longer required.