org.mule.util.journal.queue

Class LocalTxQueueTransactionJournal

java.lang.Object

org.mule.util.journal.queue.AbstractQueueTransactionJournal<Integer,LocalQueueTxJournalEntry>

org.mule.util.journal.queue.LocalTxQueueTransactionJournal

public class LocalTxQueueTransactionJournal
extends AbstractQueueTransactionJournal<Integer,LocalQueueTxJournalEntry>

Journal for operations done to a queue within a transactional context

Field Summary

Fields inherited from class org.mule.util.journal.queue.AbstractQueueTransactionJournal

logger

Constructor Summary

Constructors

Constructor and Description
LocalTxQueueTransactionJournal(String logFilesDirectory, MuleContext muleContext)

Method Summary

Methods

Modifier and Type	Method and Description
protected LocalQueueTxJournalEntry	createCheckpointJournalEntry(Integer txId, byte operation) Creates a checkpoint JournalEntry.
static JournalEntrySerializer<Integer,LocalQueueTxJournalEntry>	createLocalTxQueueJournalEntrySerializer(MuleContext muleContext)
protected LocalQueueTxJournalEntry	createUpdateJournalEntry(Integer txId, byte byteRepresentation, String queueName, Serializable value) Creates a JournalEntry for an update operation in the queue.

Methods inherited from class org.mule.util.journal.queue.AbstractQueueTransactionJournal

clear, close, getAllLogEntries, getJournal, getLogEntriesForTx, logAdd, logAddFirst, logCommit, logRemove, logRollback

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTxQueueTransactionJournal

public LocalTxQueueTransactionJournal(String logFilesDirectory,
                              MuleContext muleContext)

Method Detail

createLocalTxQueueJournalEntrySerializer

public static JournalEntrySerializer<Integer,LocalQueueTxJournalEntry> createLocalTxQueueJournalEntrySerializer(MuleContext muleContext)

createUpdateJournalEntry

protected LocalQueueTxJournalEntry createUpdateJournalEntry(Integer txId,
                                                byte byteRepresentation,
                                                String queueName,
                                                Serializable value)

Description copied from class: AbstractQueueTransactionJournal

Creates a JournalEntry for an update operation in the queue.

Specified by:

createUpdateJournalEntry in class AbstractQueueTransactionJournal<Integer,LocalQueueTxJournalEntry>

Parameters:

txId - transaction identifier

byteRepresentation - operation done over the queue

queueName - queueName of the queue in which the operation has been done

value - value of the operation

Returns:

a new JournalEntry

createCheckpointJournalEntry

protected LocalQueueTxJournalEntry createCheckpointJournalEntry(Integer txId,
                                                    byte operation)

Description copied from class: AbstractQueueTransactionJournal

Creates a checkpoint JournalEntry.

Specified by:

createCheckpointJournalEntry in class AbstractQueueTransactionJournal<Integer,LocalQueueTxJournalEntry>

Parameters:

txId - transaction identifier

operation - checkpoint operation

Returns:

a new JournalEntry