| Modifier and Type | Method and Description |
|---|---|
org.apache.activemq.artemis.core.journal.JournalLoadInformation |
StorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
Set<org.apache.activemq.artemis.api.core.Pair<Long,Long>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter,
JournalLoader journalLoader) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.activemq.artemis.core.journal.JournalLoadInformation |
AbstractJournalStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
Set<org.apache.activemq.artemis.api.core.Pair<Long,Long>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter,
JournalLoader journalLoader) |
| Modifier and Type | Class and Description |
|---|---|
class |
PageCountPendingImpl |
| Modifier and Type | Method and Description |
|---|---|
org.apache.activemq.artemis.core.journal.JournalLoadInformation |
NullStorageManager.loadMessageJournal(PostOffice postOffice,
PagingManager pagingManager,
ResourceManager resourceManager,
Map<Long,QueueBindingInfo> queueInfos,
Map<org.apache.activemq.artemis.api.core.SimpleString,List<org.apache.activemq.artemis.api.core.Pair<byte[],Long>>> duplicateIDMap,
Set<org.apache.activemq.artemis.api.core.Pair<Long,Long>> pendingLargeMessages,
List<PageCountPending> pendingNonTXPageCounter,
JournalLoader journalLoader) |
| Modifier and Type | Method and Description |
|---|---|
void |
PostOfficeJournalLoader.recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter)
This method will recover the counters after failures making sure the page counter doesn't get out of sync
|
void |
JournalLoader.recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.