public class TransactionJournal<T,K extends JournalEntry<T>> extends Object
Constructor and Description |
---|
TransactionJournal(String logFilesDirectory,
TransactionCompletePredicate transactionCompletePredicate,
JournalEntrySerializer journalEntrySerializer) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Removes all the entries from the transactional journal
|
void |
close()
Release the resources used by the transaction journal
|
com.google.common.collect.Multimap<T,K> |
getAllLogEntries() |
Collection<K> |
getLogEntriesForTx(T txId) |
void |
logCheckpointOperation(JournalEntry<T> journalEntry)
Logs a checkpoint operation over the transactions.
|
void |
logUpdateOperation(JournalEntry<T> journalEntry)
Log an update operation over a transactional resource
|
public TransactionJournal(String logFilesDirectory, TransactionCompletePredicate transactionCompletePredicate, JournalEntrySerializer journalEntrySerializer)
logFilesDirectory
- directory used to store the journal files.public void logUpdateOperation(JournalEntry<T> journalEntry)
journalEntry
- journal entry with the update operation detailspublic void logCheckpointOperation(JournalEntry<T> journalEntry)
journalEntry
- journal entry with the checkpoint operation detailspublic Collection<K> getLogEntriesForTx(T txId)
txId
- transaction identifierpublic com.google.common.collect.Multimap<T,K> getAllLogEntries()
public void close()
public void clear()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.