public class XaTxQueueTransactionJournal extends AbstractQueueTransactionJournal<Xid,XaQueueTxJournalEntry>
logger
Constructor and Description |
---|
XaTxQueueTransactionJournal(String logFilesDirectory,
MuleContext muleContext) |
Modifier and Type | Method and Description |
---|---|
protected XaQueueTxJournalEntry |
createCheckpointJournalEntry(Xid txId,
byte operation)
Creates a checkpoint
JournalEntry . |
protected XaQueueTxJournalEntry |
createUpdateJournalEntry(Xid txId,
byte operation,
String queueName,
Serializable serialize)
Creates a
JournalEntry for an update operation in the queue. |
Collection<XaQueueTxJournalEntry> |
getLogEntriesForTx(Xid txId) |
void |
logPrepare(Xid xid) |
clear, close, getAllLogEntries, getJournal, logAdd, logAddFirst, logCommit, logRemove, logRollback
public XaTxQueueTransactionJournal(String logFilesDirectory, MuleContext muleContext)
protected XaQueueTxJournalEntry createUpdateJournalEntry(Xid txId, byte operation, String queueName, Serializable serialize)
AbstractQueueTransactionJournal
JournalEntry
for an update operation in the queue.createUpdateJournalEntry
in class AbstractQueueTransactionJournal<Xid,XaQueueTxJournalEntry>
txId
- transaction identifieroperation
- operation done over the queuequeueName
- queueName of the queue in which the operation has been doneserialize
- value of the operationJournalEntry
protected XaQueueTxJournalEntry createCheckpointJournalEntry(Xid txId, byte operation)
AbstractQueueTransactionJournal
JournalEntry
.createCheckpointJournalEntry
in class AbstractQueueTransactionJournal<Xid,XaQueueTxJournalEntry>
txId
- transaction identifieroperation
- checkpoint operationJournalEntry
public void logPrepare(Xid xid)
public Collection<XaQueueTxJournalEntry> getLogEntriesForTx(Xid txId)
getLogEntriesForTx
in class AbstractQueueTransactionJournal<Xid,XaQueueTxJournalEntry>
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.