Package | Description |
---|---|
org.hornetq.core.journal | |
org.hornetq.core.journal.impl | |
org.hornetq.core.persistence | |
org.hornetq.core.persistence.impl.journal | |
org.hornetq.core.replication |
Modifier and Type | Method and Description |
---|---|
void |
Journal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
void |
Journal.appendCommitRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
Journal.appendCommitRecord(long txID,
boolean sync,
IOCompletion callback,
boolean lineUpContext) |
void |
Journal.appendDeleteRecord(long id,
boolean sync,
IOCompletion completionCallback) |
void |
Journal.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
void |
Journal.appendRollbackRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
Journal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
void |
Journal.lineUpContext(IOCompletion callback) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleWaitIOCallback
A SimpleWaitIOCallback
|
class |
SyncIOCompletion
Internal class used to manage explicit syncs on the Journal through callbacks.
|
Modifier and Type | Method and Description |
---|---|
void |
JournalImpl.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
FileWrapperJournal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.appendCommitRecord(long txID,
boolean sync,
IOCompletion callback,
boolean lineUpContext)
Regarding the number of operations in a given file see
JournalCompleteRecordTX . |
void |
FileWrapperJournal.appendCommitRecord(long txID,
boolean sync,
IOCompletion callback,
boolean lineUpContext) |
void |
JournalImpl.appendDeleteRecord(long id,
boolean sync,
IOCompletion callback) |
void |
FileWrapperJournal.appendDeleteRecord(long id,
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.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.appendRollbackRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
FileWrapperJournal.appendRollbackRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
FileWrapperJournal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
JournalImpl.lineUpContext(IOCompletion callback) |
void |
FileWrapperJournal.lineUpContext(IOCompletion callback) |
Modifier and Type | Interface and Description |
---|---|
interface |
OperationContext
This represents a set of operations done as part of replication.
|
Modifier and Type | Class and Description |
---|---|
class |
OperationContextImpl
Each instance of OperationContextImpl is associated with an executor (usually an ordered Executor).
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedJournal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
void |
ReplicatedJournal.appendCommitRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
ReplicatedJournal.appendCommitRecord(long txID,
boolean sync,
IOCompletion callback,
boolean lineUpContext) |
void |
ReplicatedJournal.appendDeleteRecord(long id,
boolean sync,
IOCompletion completionCallback) |
void |
ReplicatedJournal.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
void |
ReplicatedJournal.appendRollbackRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
ReplicatedJournal.appendUpdateRecord(long id,
byte journalRecordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
void |
ReplicatedJournal.lineUpContext(IOCompletion callback) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.