public class JDBCJournalLoaderCallback extends Object implements LoaderCallback
Constructor and Description |
---|
JDBCJournalLoaderCallback(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback,
boolean fixBadTX) |
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) |
public JDBCJournalLoaderCallback(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback failureCallback, boolean fixBadTX)
public void checkMaxId(long id)
public void addPreparedTransaction(PreparedTransactionInfo preparedTransaction)
addPreparedTransaction
in interface LoaderCallback
public void addRecord(RecordInfo info)
addRecord
in interface LoaderCallback
public void updateRecord(RecordInfo info)
updateRecord
in interface LoaderCallback
public void deleteRecord(long id)
deleteRecord
in interface LoaderCallback
public void failedTransaction(long transactionID, List<RecordInfo> records, List<RecordInfo> recordsToDelete)
TransactionFailureCallback
failedTransaction
in interface TransactionFailureCallback
public long getMaxId()
Copyright © 2016 The Apache Software Foundation. All rights reserved.