org.hornetq.core.journal.impl

Interface JournalReaderCallback

All Known Implementing Classes:

AbstractJournalUpdateTask, JournalCompactor, JournalReaderCallbackAbstract

public interface JournalReaderCallback

A JournalReader

Author:

Clebert Suconic

Method Summary

Methods

Modifier and Type	Method and Description
void	markAsDataFile(JournalFile file)
void	onReadAddRecord(RecordInfo info)
void	onReadAddRecordTX(long transactionID, RecordInfo recordInfo)
void	onReadCommitRecord(long transactionID, int numberOfRecords)
void	onReadDeleteRecord(long recordID)
void	onReadDeleteRecordTX(long transactionID, RecordInfo recordInfo)
void	onReadPrepareRecord(long transactionID, byte[] extraData, int numberOfRecords)
void	onReadRollbackRecord(long transactionID)
void	onReadUpdateRecord(RecordInfo recordInfo)
void	onReadUpdateRecordTX(long transactionID, RecordInfo recordInfo)

Method Detail

onReadAddRecord

void onReadAddRecord(RecordInfo info)
                     throws Exception

Throws:

Exception

onReadUpdateRecord

void onReadUpdateRecord(RecordInfo recordInfo)
                        throws Exception

Parameters:

recordInfo -

Throws:

Exception

onReadDeleteRecord

void onReadDeleteRecord(long recordID)
                        throws Exception

Parameters:

recordID -

Throws:

Exception

onReadAddRecordTX

void onReadAddRecordTX(long transactionID,
                     RecordInfo recordInfo)
                       throws Exception

Parameters:

transactionID -

recordInfo -

Throws:

Exception

onReadUpdateRecordTX

void onReadUpdateRecordTX(long transactionID,
                        RecordInfo recordInfo)
                          throws Exception

Parameters:

transactionID -

recordInfo -

Throws:

Exception

onReadDeleteRecordTX

void onReadDeleteRecordTX(long transactionID,
                        RecordInfo recordInfo)
                          throws Exception

Parameters:

transactionID -

recordInfo -

Throws:

Exception

onReadPrepareRecord

void onReadPrepareRecord(long transactionID,
                       byte[] extraData,
                       int numberOfRecords)
                         throws Exception

Parameters:

transactionID -

extraData -

numberOfRecords -

Throws:

Exception

onReadCommitRecord

void onReadCommitRecord(long transactionID,
                      int numberOfRecords)
                        throws Exception

Parameters:

transactionID -

numberOfRecords -

Throws:

Exception

onReadRollbackRecord

void onReadRollbackRecord(long transactionID)
                          throws Exception

Parameters:

transactionID -

Throws:

Exception

markAsDataFile

void markAsDataFile(JournalFile file)