Package | Description |
---|---|
org.hornetq.core.journal | |
org.hornetq.core.journal.impl | |
org.hornetq.core.persistence.impl.journal | |
org.hornetq.core.replication.impl |
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 |
JournalReaderCallbackAbstract.onReadAddRecord(RecordInfo info) |
void |
JournalReaderCallback.onReadAddRecord(RecordInfo info) |
void |
JournalCompactor.onReadAddRecord(RecordInfo info) |
void |
JournalReaderCallbackAbstract.onReadAddRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallback.onReadAddRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadAddRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallbackAbstract.onReadDeleteRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallback.onReadDeleteRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadDeleteRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallbackAbstract.onReadUpdateRecord(RecordInfo recordInfo) |
void |
JournalReaderCallback.onReadUpdateRecord(RecordInfo recordInfo) |
void |
JournalCompactor.onReadUpdateRecord(RecordInfo info) |
void |
JournalReaderCallbackAbstract.onReadUpdateRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallback.onReadUpdateRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadUpdateRecordTX(long transactionID,
RecordInfo info) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
JournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback) |
JournalLoadInformation |
JournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback,
boolean changeData) |
Modifier and Type | Method and Description |
---|---|
static Object |
JournalStorageManager.newObjectEncoding(RecordInfo info) |
static Object |
JournalStorageManager.newObjectEncoding(RecordInfo info,
JournalStorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
ReplicatedJournal.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.