org.jboss.messaging.core.journal.impl
Interface JournalReaderCallback

All Known Implementing Classes:
JournalCompactor, JournalReaderCallbackAbstract

public interface JournalReaderCallback

A JournalReader

Author:
Clebert Suconic

Method Summary
 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 java.lang.Exception
Throws:
java.lang.Exception

onReadUpdateRecord

void onReadUpdateRecord(RecordInfo recordInfo)
                        throws java.lang.Exception
Parameters:
recordInfo -
Throws:
java.lang.Exception

onReadDeleteRecord

void onReadDeleteRecord(long recordID)
                        throws java.lang.Exception
Parameters:
recordID -
Throws:
java.lang.Exception

onReadAddRecordTX

void onReadAddRecordTX(long transactionID,
                       RecordInfo recordInfo)
                       throws java.lang.Exception
Parameters:
transactionID -
recordInfo -
Throws:
java.lang.Exception

onReadUpdateRecordTX

void onReadUpdateRecordTX(long transactionID,
                          RecordInfo recordInfo)
                          throws java.lang.Exception
Parameters:
transactionID -
recordInfo -
Throws:
java.lang.Exception

onReadDeleteRecordTX

void onReadDeleteRecordTX(long transactionID,
                          RecordInfo recordInfo)
                          throws java.lang.Exception
Parameters:
transactionID -
recordInfo -
Throws:
java.lang.Exception

onReadPrepareRecord

void onReadPrepareRecord(long transactionID,
                         byte[] extraData,
                         int numberOfRecords)
                         throws java.lang.Exception
Parameters:
transactionID -
extraData -
summaryData -
Throws:
java.lang.Exception

onReadCommitRecord

void onReadCommitRecord(long transactionID,
                        int numberOfRecords)
                        throws java.lang.Exception
Parameters:
transactionID -
summaryData -
Throws:
java.lang.Exception

onReadRollbackRecord

void onReadRollbackRecord(long transactionID)
                          throws java.lang.Exception
Parameters:
transactionID -
Throws:
java.lang.Exception

markAsDataFile

void markAsDataFile(JournalFile file)


Copyright © 2006 JBoss Inc. All Rights Reserved.