| Package | Description |
|---|---|
| org.hornetq.core.journal | |
| org.hornetq.core.journal.impl | |
| org.hornetq.core.persistence.impl.journal | |
| org.hornetq.core.replication |
| Modifier and Type | Field and Description |
|---|---|
List<RecordInfo> |
PreparedTransactionInfo.records |
List<RecordInfo> |
PreparedTransactionInfo.recordsToDelete |
| Modifier and Type | Method and Description |
|---|---|
void |
LoaderCallback.addRecord(RecordInfo info) |
void |
LoaderCallback.updateRecord(RecordInfo info) |
| Modifier and Type | Method and Description |
|---|---|
void |
TransactionFailureCallback.failedTransaction(long transactionID,
List<RecordInfo> records,
List<RecordInfo> recordsToDelete)
To be used to inform about transactions without commit records.
|
void |
TransactionFailureCallback.failedTransaction(long transactionID,
List<RecordInfo> records,
List<RecordInfo> recordsToDelete)
To be used to inform about transactions without commit records.
|
JournalLoadInformation |
Journal.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
| Modifier and Type | Method and Description |
|---|---|
protected static RecordInfo |
ImportJournal.parseRecord(Properties properties) |
| Modifier and Type | Method and Description |
|---|---|
void |
JournalCompactor.onReadAddRecord(RecordInfo info) |
void |
JournalReaderCallback.onReadAddRecord(RecordInfo info) |
void |
JournalReaderCallbackAbstract.onReadAddRecord(RecordInfo info) |
void |
JournalCompactor.onReadAddRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallback.onReadAddRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadAddRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadDeleteRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallback.onReadDeleteRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadDeleteRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadUpdateRecord(RecordInfo info) |
void |
JournalReaderCallback.onReadUpdateRecord(RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadUpdateRecord(RecordInfo recordInfo) |
void |
JournalCompactor.onReadUpdateRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallback.onReadUpdateRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadUpdateRecordTX(long transactionID,
RecordInfo recordInfo) |
| Modifier and Type | Method and Description |
|---|---|
JournalLoadInformation |
JournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback) |
JournalLoadInformation |
FileWrapperJournal.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
JournalLoadInformation |
JournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback,
boolean fixBadTX) |
| Modifier and Type | Method and Description |
|---|---|
static Object |
DescribeJournal.newObjectEncoding(RecordInfo info) |
static Object |
DescribeJournal.newObjectEncoding(RecordInfo info,
JournalStorageManager storageManager) |
| Modifier and Type | Method and Description |
|---|---|
JournalLoadInformation |
ReplicatedJournal.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.