org.apache.activemq.artemis.jdbc.store.journal

Class JDBCJournalLoaderCallback

java.lang.Object

org.apache.activemq.artemis.jdbc.store.journal.JDBCJournalLoaderCallback

All Implemented Interfaces:

LoaderCallback, TransactionFailureCallback

public class JDBCJournalLoaderCallback
extends Object
implements LoaderCallback

Constructor Summary

Constructors

Constructor and Description
JDBCJournalLoaderCallback(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback failureCallback, boolean fixBadTX)

Method Summary

Modifier and Type	Method and Description
void	addPreparedTransaction(PreparedTransactionInfo preparedTransaction)
void	addRecord(RecordInfo info)
void	checkMaxId(long id)
void	deleteRecord(long id)
void	failedTransaction(long transactionID, List<RecordInfo> records, List<RecordInfo> recordsToDelete) To be used to inform about transactions without commit records.
long	getMaxId()
void	updateRecord(RecordInfo info)

Methods inherited from class java.lang.Object

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

Constructor Detail

JDBCJournalLoaderCallback

public JDBCJournalLoaderCallback(List<RecordInfo> committedRecords,
                                 List<PreparedTransactionInfo> preparedTransactions,
                                 TransactionFailureCallback failureCallback,
                                 boolean fixBadTX)

Method Detail

checkMaxId

public void checkMaxId(long id)

addPreparedTransaction

public void addPreparedTransaction(PreparedTransactionInfo preparedTransaction)

Specified by:

addPreparedTransaction in interface LoaderCallback

addRecord

public void addRecord(RecordInfo info)

Specified by:

addRecord in interface LoaderCallback

updateRecord

public void updateRecord(RecordInfo info)

Specified by:

updateRecord in interface LoaderCallback

deleteRecord

public void deleteRecord(long id)

Specified by:

deleteRecord in interface LoaderCallback

failedTransaction

public void failedTransaction(long transactionID,
                              List<RecordInfo> records,
                              List<RecordInfo> recordsToDelete)

Description copied from interface: TransactionFailureCallback

To be used to inform about transactions without commit records. This could be used to remove extra resources associated with the transactions (such as external files received during the transaction)

Specified by:

failedTransaction in interface TransactionFailureCallback

getMaxId

public long getMaxId()