public interface Journal extends HornetQComponent
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() |
isStarted, start, stop
void appendAddRecord(long id, byte recordType, byte[] record, boolean sync) throws Exception
Exception
void appendAddRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion completionCallback) throws Exception
Exception
void appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync) throws Exception
Exception
void appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion completionCallback) throws Exception
Exception
void appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync) throws Exception
Exception
void appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion completionCallback) throws Exception
Exception
void appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync) throws Exception
Exception
void appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion completionCallback) throws Exception
Exception
void appendDeleteRecord(long id, boolean sync) throws Exception
Exception
void appendDeleteRecord(long id, boolean sync, IOCompletion completionCallback) throws Exception
Exception
void appendAddRecordTransactional(long txID, long id, byte recordType, byte[] record) throws Exception
Exception
void appendAddRecordTransactional(long txID, long id, byte recordType, EncodingSupport record) throws Exception
Exception
void appendUpdateRecordTransactional(long txID, long id, byte recordType, byte[] record) throws Exception
Exception
void appendUpdateRecordTransactional(long txID, long id, byte recordType, EncodingSupport record) throws Exception
Exception
void appendDeleteRecordTransactional(long txID, long id, byte[] record) throws Exception
Exception
void appendDeleteRecordTransactional(long txID, long id, EncodingSupport record) throws Exception
Exception
void appendDeleteRecordTransactional(long txID, long id) throws Exception
Exception
void appendCommitRecord(long txID, boolean sync) throws Exception
Exception
void appendCommitRecord(long txID, boolean sync, IOCompletion callback) throws Exception
Exception
void appendCommitRecord(long txID, boolean sync, IOCompletion callback, boolean lineUpContext) throws Exception
txID
- sync
- callback
- useLineUp
- if appendCommitRecord should call a storeLineUp. This is because the caller may have already taken into accountException
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
txID
- transactionData
- - extra user data for the prepareException
void appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync, IOCompletion callback) throws Exception
Exception
void appendPrepareRecord(long txID, byte[] transactionData, boolean sync) throws Exception
Exception
void appendPrepareRecord(long txID, byte[] transactionData, boolean sync, IOCompletion callback) throws Exception
Exception
void appendRollbackRecord(long txID, boolean sync) throws Exception
Exception
void appendRollbackRecord(long txID, boolean sync, IOCompletion callback) throws Exception
Exception
JournalLoadInformation load(LoaderCallback reloadManager) throws Exception
Exception
JournalLoadInformation loadInternalOnly() throws Exception
Exception
void lineUpContex(IOCompletion callback)
JournalLoadInformation load(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback transactionFailure) throws Exception
Exception
int getNumberOfRecords()
int getUserVersion()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.