Package | Description |
---|---|
org.hornetq.core.journal | |
org.hornetq.core.journal.impl | |
org.hornetq.core.journal.impl.dataformat |
Modifier and Type | Method and Description |
---|---|
void |
Journal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync) |
void |
Journal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
void |
Journal.appendAddRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
Journal.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
Journal.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 |
Journal.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
void |
Journal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync) |
void |
Journal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
void |
Journal.appendUpdateRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
SequentialFile.write(EncodingSupport bytes,
boolean sync) |
void |
SequentialFile.write(EncodingSupport bytes,
boolean sync,
IOAsyncTask callback) |
Modifier and Type | Method and Description |
---|---|
void |
TimedBuffer.addBytes(EncodingSupport bytes,
boolean sync,
IOAsyncTask callback) |
void |
FileWrapperJournal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
FileWrapperJournal.appendAddRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
JournalImpl.appendAddRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
FileWrapperJournal.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
JournalImpl.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
FileWrapperJournal.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback)
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 |
FileWrapperJournal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
FileWrapperJournal.appendUpdateRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
JournalImpl.appendUpdateRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
AbstractSequentialFile.write(EncodingSupport bytes,
boolean sync) |
void |
AbstractSequentialFile.write(EncodingSupport bytes,
boolean sync,
IOAsyncTask callback) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayEncoding
A ByteArrayEncoding
|
class |
JournalAddRecord
A JournalAddRecord
|
class |
JournalAddRecordTX
A JournalAddRecordTX
|
class |
JournalCompleteRecordTX
A transaction record (Commit or Prepare), will hold the number of elements the transaction has in
the current file.
|
class |
JournalDeleteRecord
A JournalDeleteRecord
|
class |
JournalDeleteRecordTX
A JournalDeleteRecordTX
|
class |
JournalInternalRecord
A InternalEncoder
|
class |
JournalRollbackRecordTX
A JournalRollbackRecordTX
|
Constructor and Description |
---|
JournalAddRecord(boolean add,
long id,
byte recordType,
EncodingSupport record) |
JournalAddRecordTX(boolean add,
long txID,
long id,
byte recordType,
EncodingSupport record) |
JournalCompleteRecordTX(JournalCompleteRecordTX.TX_RECORD_TYPE isCommit,
long txID,
EncodingSupport transactionData) |
JournalDeleteRecordTX(long txID,
long id,
EncodingSupport record) |
Copyright © 2016 JBoss, a division of Red Hat. All Rights Reserved.