org.hornetq.core.journal

Interface Journal

All Superinterfaces:

HornetQComponent

All Known Subinterfaces:

TestableJournal

All Known Implementing Classes:

JournalImpl, ReplicatedJournal

public interface Journal
extends HornetQComponent

Most methods on the journal provide a blocking version where you select the sync mode and a non blocking mode where you pass a completion callback as a parameter. Notice also that even on the callback methods it's possible to pass the sync mode. That will only make sense on the NIO operations.

Author:

Tim Fox, Clebert Suconic

Method Summary

Methods

Modifier and Type	Method and Description
void	appendAddRecord(long id, byte recordType, byte[] record, boolean sync)
void	appendAddRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion completionCallback)
void	appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync)
void	appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion completionCallback)
void	appendAddRecordTransactional(long txID, long id, byte recordType, byte[] record)
void	appendAddRecordTransactional(long txID, long id, byte recordType, EncodingSupport record)
void	appendCommitRecord(long txID, boolean sync)
void	appendCommitRecord(long txID, boolean sync, IOCompletion callback)
void	appendCommitRecord(long txID, boolean sync, IOCompletion callback, boolean lineUpContext)
void	appendDeleteRecord(long id, boolean sync)
void	appendDeleteRecord(long id, boolean sync, IOCompletion completionCallback)
void	appendDeleteRecordTransactional(long txID, long id)
void	appendDeleteRecordTransactional(long txID, long id, byte[] record)
void	appendDeleteRecordTransactional(long txID, long id, EncodingSupport record)
void	appendPrepareRecord(long txID, byte[] transactionData, boolean sync)
void	appendPrepareRecord(long txID, byte[] transactionData, boolean sync, IOCompletion callback)
void	appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync) If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
void	appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync, IOCompletion callback)
void	appendRollbackRecord(long txID, boolean sync)
void	appendRollbackRecord(long txID, boolean sync, IOCompletion callback)
void	appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync)
void	appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion completionCallback)
void	appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync)
void	appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion completionCallback)
void	appendUpdateRecordTransactional(long txID, long id, byte recordType, byte[] record)
void	appendUpdateRecordTransactional(long txID, long id, byte recordType, EncodingSupport record)
int	getAlignment()
int	getNumberOfRecords()
int	getUserVersion()
void	lineUpContex(IOCompletion callback)
JournalLoadInformation	load(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback transactionFailure)
JournalLoadInformation	load(LoaderCallback reloadManager)
JournalLoadInformation	loadInternalOnly() Load internal data structures and not expose any data.
void	perfBlast(int pages)
void	runDirectJournalBlast()

Methods inherited from interface org.hornetq.core.server.HornetQComponent

isStarted, start, stop

Method Detail

appendAddRecord

void appendAddRecord(long id,
                   byte recordType,
                   byte[] record,
                   boolean sync)
                     throws Exception

Throws:

Exception

appendAddRecord

void appendAddRecord(long id,
                   byte recordType,
                   byte[] record,
                   boolean sync,
                   IOCompletion completionCallback)
                     throws Exception

Throws:

Exception

appendAddRecord

void appendAddRecord(long id,
                   byte recordType,
                   EncodingSupport record,
                   boolean sync)
                     throws Exception

Throws:

Exception

appendAddRecord

void appendAddRecord(long id,
                   byte recordType,
                   EncodingSupport record,
                   boolean sync,
                   IOCompletion completionCallback)
                     throws Exception

Throws:

Exception

appendUpdateRecord

void appendUpdateRecord(long id,
                      byte recordType,
                      byte[] record,
                      boolean sync)
                        throws Exception

Throws:

Exception

appendUpdateRecord

void appendUpdateRecord(long id,
                      byte recordType,
                      byte[] record,
                      boolean sync,
                      IOCompletion completionCallback)
                        throws Exception

Throws:

Exception

appendUpdateRecord

void appendUpdateRecord(long id,
                      byte recordType,
                      EncodingSupport record,
                      boolean sync)
                        throws Exception

Throws:

Exception

appendUpdateRecord

void appendUpdateRecord(long id,
                      byte recordType,
                      EncodingSupport record,
                      boolean sync,
                      IOCompletion completionCallback)
                        throws Exception

Throws:

Exception

appendDeleteRecord

void appendDeleteRecord(long id,
                      boolean sync)
                        throws Exception

Throws:

Exception

appendDeleteRecord

void appendDeleteRecord(long id,
                      boolean sync,
                      IOCompletion completionCallback)
                        throws Exception

Throws:

Exception

appendAddRecordTransactional

void appendAddRecordTransactional(long txID,
                                long id,
                                byte recordType,
                                byte[] record)
                                  throws Exception

Throws:

Exception

appendAddRecordTransactional

void appendAddRecordTransactional(long txID,
                                long id,
                                byte recordType,
                                EncodingSupport record)
                                  throws Exception

Throws:

Exception

appendUpdateRecordTransactional

void appendUpdateRecordTransactional(long txID,
                                   long id,
                                   byte recordType,
                                   byte[] record)
                                     throws Exception

Throws:

Exception

appendUpdateRecordTransactional

void appendUpdateRecordTransactional(long txID,
                                   long id,
                                   byte recordType,
                                   EncodingSupport record)
                                     throws Exception

Throws:

Exception

appendDeleteRecordTransactional

void appendDeleteRecordTransactional(long txID,
                                   long id,
                                   byte[] record)
                                     throws Exception

Throws:

Exception

appendDeleteRecordTransactional

void appendDeleteRecordTransactional(long txID,
                                   long id,
                                   EncodingSupport record)
                                     throws Exception

Throws:

Exception

appendDeleteRecordTransactional

void appendDeleteRecordTransactional(long txID,
                                   long id)
                                     throws Exception

Throws:

Exception

appendCommitRecord

void appendCommitRecord(long txID,
                      boolean sync)
                        throws Exception

Throws:

Exception

appendCommitRecord

void appendCommitRecord(long txID,
                      boolean sync,
                      IOCompletion callback)
                        throws Exception

Throws:

Exception

appendCommitRecord

void appendCommitRecord(long txID,
                      boolean sync,
                      IOCompletion callback,
                      boolean lineUpContext)
                        throws Exception

Parameters:

txID -

sync -

callback -

useLineUp - if appendCommitRecord should call a storeLineUp. This is because the caller may have already taken into account

Throws:

Exception

appendPrepareRecord

void appendPrepareRecord(long txID,
                       EncodingSupport transactionData,
                       boolean sync)
                         throws Exception

If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.

transactionData allows you to store any other supporting user-data related to the transaction

Parameters:

txID -

transactionData - - extra user data for the prepare

Throws:

Exception

appendPrepareRecord

void appendPrepareRecord(long txID,
                       EncodingSupport transactionData,
                       boolean sync,
                       IOCompletion callback)
                         throws Exception

Throws:

Exception

appendPrepareRecord

void appendPrepareRecord(long txID,
                       byte[] transactionData,
                       boolean sync)
                         throws Exception

Throws:

Exception

appendPrepareRecord

void appendPrepareRecord(long txID,
                       byte[] transactionData,
                       boolean sync,
                       IOCompletion callback)
                         throws Exception

Throws:

Exception

appendRollbackRecord

void appendRollbackRecord(long txID,
                        boolean sync)
                          throws Exception

Throws:

Exception

appendRollbackRecord

void appendRollbackRecord(long txID,
                        boolean sync,
                        IOCompletion callback)
                          throws Exception

Throws:

Exception

load

JournalLoadInformation load(LoaderCallback reloadManager)
                            throws Exception

Throws:

Exception

loadInternalOnly

JournalLoadInformation loadInternalOnly()
                                        throws Exception

Load internal data structures and not expose any data. This is only useful if you're using the journal but not interested on the current data. Useful in situations where the journal is being replicated, copied... etc.

Throws:

Exception

lineUpContex

void lineUpContex(IOCompletion callback)

load

JournalLoadInformation load(List<RecordInfo> committedRecords,
                          List<PreparedTransactionInfo> preparedTransactions,
                          TransactionFailureCallback transactionFailure)
                            throws Exception

Throws:

Exception

getAlignment

int getAlignment()
                 throws Exception

Throws:

Exception

getNumberOfRecords

int getNumberOfRecords()

getUserVersion

int getUserVersion()

perfBlast

void perfBlast(int pages)
               throws Exception

Throws:

Exception

runDirectJournalBlast

void runDirectJournalBlast()
                           throws Exception

Throws:

Exception