public class JDBCJournalReaderCallback extends Object implements JournalReaderCallback
Constructor and Description |
---|
JDBCJournalReaderCallback(LoaderCallback loadManager) |
Modifier and Type | Method and Description |
---|---|
void |
checkPreparedTx() |
Map<Long,org.apache.activemq.artemis.jdbc.store.journal.TransactionHolder> |
getTransactions() |
void |
markAsDataFile(JournalFile file) |
void |
onReadAddRecord(RecordInfo info) |
void |
onReadAddRecordTX(long transactionID,
RecordInfo info) |
void |
onReadCommitRecord(long transactionID,
int numberOfRecords) |
void |
onReadDeleteRecord(long recordID) |
void |
onReadDeleteRecordTX(long transactionID,
RecordInfo info) |
void |
onReadPrepareRecord(long transactionID,
byte[] extraData,
int numberOfRecords) |
void |
onReadRollbackRecord(long transactionID) |
void |
onReadUpdateRecord(RecordInfo info) |
void |
onReadUpdateRecordTX(long transactionID,
RecordInfo info) |
public JDBCJournalReaderCallback(LoaderCallback loadManager)
public void onReadAddRecord(RecordInfo info) throws Exception
onReadAddRecord
in interface JournalReaderCallback
Exception
public void onReadUpdateRecord(RecordInfo info) throws Exception
onReadUpdateRecord
in interface JournalReaderCallback
Exception
public void onReadDeleteRecord(long recordID) throws Exception
onReadDeleteRecord
in interface JournalReaderCallback
Exception
public void onReadUpdateRecordTX(long transactionID, RecordInfo info) throws Exception
onReadUpdateRecordTX
in interface JournalReaderCallback
Exception
public void onReadAddRecordTX(long transactionID, RecordInfo info) throws Exception
onReadAddRecordTX
in interface JournalReaderCallback
Exception
public void onReadDeleteRecordTX(long transactionID, RecordInfo info) throws Exception
onReadDeleteRecordTX
in interface JournalReaderCallback
Exception
public void onReadPrepareRecord(long transactionID, byte[] extraData, int numberOfRecords) throws Exception
onReadPrepareRecord
in interface JournalReaderCallback
Exception
public void onReadCommitRecord(long transactionID, int numberOfRecords) throws Exception
onReadCommitRecord
in interface JournalReaderCallback
Exception
public void onReadRollbackRecord(long transactionID) throws Exception
onReadRollbackRecord
in interface JournalReaderCallback
Exception
public void markAsDataFile(JournalFile file)
markAsDataFile
in interface JournalReaderCallback
public void checkPreparedTx()
Copyright © 2016 The Apache Software Foundation. All rights reserved.