Modifier and Type | Method and Description |
---|---|
void |
SequentialFile.write(EncodingSupport bytes,
boolean sync) |
void |
AbstractSequentialFile.write(EncodingSupport bytes,
boolean sync) |
void |
SequentialFile.write(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
void |
AbstractSequentialFile.write(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
TimedBuffer.addBytes(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
Modifier and Type | Method and Description |
---|---|
EncodingSupport |
EncoderPersister.decode(ActiveMQBuffer buffer,
EncodingSupport record) |
Modifier and Type | Method and Description |
---|---|
default void |
Journal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync) |
default void |
Journal.appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
default 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) |
default void |
Journal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync) |
default void |
Journal.appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion completionCallback) |
default void |
Journal.appendUpdateRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
EncodingSupport |
EncoderPersister.decode(ActiveMQBuffer buffer,
EncodingSupport record) |
void |
EncoderPersister.encode(ActiveMQBuffer buffer,
EncodingSupport record) |
int |
EncoderPersister.getEncodeSize(EncodingSupport record) |
Modifier and Type | Method and Description |
---|---|
void |
JournalImpl.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
FileWrapperJournal.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayEncoding |
class |
JournalAddRecord |
class |
JournalAddRecordTX |
class |
JournalCompleteRecordTX
A transaction record (Commit or Prepare), will hold the number of elements the transaction has in
the current file.
|
class |
JournalDeleteRecord |
class |
JournalDeleteRecordTX |
class |
JournalInternalRecord |
class |
JournalRollbackRecordTX |
Constructor and Description |
---|
JournalCompleteRecordTX(JournalCompleteRecordTX.TX_RECORD_TYPE isCommit,
long txID,
EncodingSupport transactionData) |
JournalDeleteRecordTX(long txID,
long id,
EncodingSupport record) |
Modifier and Type | Interface and Description |
---|---|
interface |
PagedMessage
A Paged message.
|
interface |
PageTransactionInfo |
Modifier and Type | Class and Description |
---|---|
class |
PagedMessageImpl
This class represents a paged message
|
class |
PageTransactionInfoImpl |
Modifier and Type | Class and Description |
---|---|
class |
PersistedAddressSetting |
class |
PersistedRoles |
Modifier and Type | Class and Description |
---|---|
protected static class |
BatchingIDGenerator.IDCounterEncoding |
Modifier and Type | Method and Description |
---|---|
static EncodingSupport |
BatchingIDGenerator.createIDEncodingSupport(long id) |
Modifier and Type | Class and Description |
---|---|
class |
CursorAckRecordEncoding |
class |
DeleteEncoding |
class |
DeliveryCountUpdateEncoding |
class |
DuplicateIDEncoding |
class |
GroupingEncoding |
class |
HeuristicCompletionEncoding |
class |
PageCountPendingImpl |
class |
PageCountRecord |
class |
PageCountRecordInc |
class |
PageUpdateTXEncoding |
class |
PendingLargeMessageEncoding |
class |
PersistentAddressBindingEncoding |
class |
PersistentQueueBindingEncoding |
class |
QueueEncoding |
class |
QueueStatusEncoding |
class |
RefEncoding |
class |
ScheduledDeliveryEncoding |
class |
XidEncoding
It's public as other classes may want to unparse data on tools
|
Constructor and Description |
---|
ReplicationDeleteTXMessage(byte journalID,
long txId,
long id,
EncodingSupport encodingData) |
ReplicationPrepareMessage(byte journalID,
long txId,
EncodingSupport encodingData) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.appendDeleteRecordTransactional(byte journalID,
long txID,
long id,
EncodingSupport record) |
void |
ReplicatedJournal.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
ReplicationManager.appendPrepareRecord(byte journalID,
long txID,
EncodingSupport transactionData) |
void |
ReplicatedJournal.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync) |
void |
ReplicatedJournal.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
Modifier and Type | Class and Description |
---|---|
class |
AddressSettings
Configuration settings that are applied on the address level
|
class |
ResourceLimitSettings |
Modifier and Type | Method and Description |
---|---|
void |
JDBCSequentialFile.write(EncodingSupport bytes,
boolean sync) |
void |
JDBCSequentialFile.write(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCJournalImpl.appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
JDBCJournalImpl.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync) |
void |
JDBCJournalImpl.appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
Modifier and Type | Class and Description |
---|---|
class |
PersistedBindings |
class |
PersistedConnectionFactory |
class |
PersistedDestination |
Modifier and Type | Interface and Description |
---|---|
interface |
ConnectionFactoryConfiguration
A ConnectionFactoryConfiguration for
ConnectionFactory objects. |
Modifier and Type | Class and Description |
---|---|
class |
ConnectionFactoryConfigurationImpl
This class contains the configuration properties of a connection factory.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.