Modifier and Type | Method and Description |
---|---|
protected static RecordInfo |
DecodeJournal.parseRecord(Properties properties) |
Modifier and Type | Method and Description |
---|---|
protected static org.apache.activemq.artemis.cli.commands.tools.PrintData.PageCursorsInfo |
PrintData.calculateCursorsInfo(List<RecordInfo> records)
Calculate the acks on the page system
|
Modifier and Type | Method and Description |
---|---|
List<RecordInfo> |
PreparedTransactionInfo.getRecords() |
List<RecordInfo> |
PreparedTransactionInfo.getRecordsToDelete() |
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 |
---|---|
void |
JournalReaderCallbackAbstract.onReadAddRecord(RecordInfo info) |
void |
JournalCompactor.onReadAddRecord(RecordInfo info) |
void |
JournalReaderCallback.onReadAddRecord(RecordInfo info) |
void |
JournalReaderCallbackAbstract.onReadAddRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadAddRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallback.onReadAddRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadDeleteRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadDeleteRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallback.onReadDeleteRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadUpdateRecord(RecordInfo recordInfo) |
void |
JournalCompactor.onReadUpdateRecord(RecordInfo info) |
void |
JournalReaderCallback.onReadUpdateRecord(RecordInfo recordInfo) |
void |
JournalReaderCallbackAbstract.onReadUpdateRecordTX(long transactionID,
RecordInfo recordInfo) |
void |
JournalCompactor.onReadUpdateRecordTX(long transactionID,
RecordInfo info) |
void |
JournalReaderCallback.onReadUpdateRecordTX(long transactionID,
RecordInfo recordInfo) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
FileWrapperJournal.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
JournalLoadInformation |
JournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback) |
JournalLoadInformation |
JournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback,
boolean fixBadTX) |
Modifier and Type | Method and Description |
---|---|
List<RecordInfo> |
DescribeJournal.getRecords() |
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 |
---|---|
void |
LargeMessageTXFailureCallback.failedTransaction(long transactionID,
List<RecordInfo> records,
List<RecordInfo> recordsToDelete) |
void |
LargeMessageTXFailureCallback.failedTransaction(long transactionID,
List<RecordInfo> records,
List<RecordInfo> recordsToDelete) |
Constructor and Description |
---|
DescribeJournal(List<RecordInfo> records,
List<PreparedTransactionInfo> preparedTransactions) |
Modifier and Type | Method and Description |
---|---|
JournalLoadInformation |
ReplicatedJournal.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
Modifier and Type | Method and Description |
---|---|
RecordInfo |
JDBCJournalRecord.toRecordInfo() |
Modifier and Type | Method and Description |
---|---|
void |
JDBCJournalLoaderCallback.addRecord(RecordInfo info) |
void |
JDBCJournalReaderCallback.onReadAddRecord(RecordInfo info) |
void |
JDBCJournalReaderCallback.onReadAddRecordTX(long transactionID,
RecordInfo info) |
void |
JDBCJournalReaderCallback.onReadDeleteRecordTX(long transactionID,
RecordInfo info) |
void |
JDBCJournalReaderCallback.onReadUpdateRecord(RecordInfo info) |
void |
JDBCJournalReaderCallback.onReadUpdateRecordTX(long transactionID,
RecordInfo info) |
void |
JDBCJournalLoaderCallback.updateRecord(RecordInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCJournalLoaderCallback.failedTransaction(long transactionID,
List<RecordInfo> records,
List<RecordInfo> recordsToDelete) |
void |
JDBCJournalLoaderCallback.failedTransaction(long transactionID,
List<RecordInfo> records,
List<RecordInfo> recordsToDelete) |
JournalLoadInformation |
JDBCJournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
JournalLoadInformation |
JDBCJournalImpl.load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback,
boolean fixBadTX) |
Constructor and Description |
---|
JDBCJournalLoaderCallback(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback failureCallback,
boolean fixBadTX) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.