Uses of Interface
org.apache.activemq.artemis.core.persistence.impl.PageCountPending
Packages that use PageCountPending
Package
Description
-
Uses of PageCountPending in org.apache.activemq.artemis.core.persistence
Method parameters in org.apache.activemq.artemis.core.persistence with type arguments of type PageCountPendingModifier and TypeMethodDescriptiondefault JournalLoadInformationStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader) default JournalLoadInformationStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> largeMessagesInFolder, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader) StorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> largeMessagesInFolder, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraRecordsLoader) -
Uses of PageCountPending in org.apache.activemq.artemis.core.persistence.impl.journal
Method parameters in org.apache.activemq.artemis.core.persistence.impl.journal with type arguments of type PageCountPendingModifier and TypeMethodDescriptionAbstractJournalStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> storedLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> journalRecordsListener) -
Uses of PageCountPending in org.apache.activemq.artemis.core.persistence.impl.journal.codec
Classes in org.apache.activemq.artemis.core.persistence.impl.journal.codec that implement PageCountPending -
Uses of PageCountPending in org.apache.activemq.artemis.core.persistence.impl.nullpm
Method parameters in org.apache.activemq.artemis.core.persistence.impl.nullpm with type arguments of type PageCountPendingModifier and TypeMethodDescriptionNullStorageManager.loadMessageJournal(PostOffice postOffice, PagingManager pagingManager, ResourceManager resourceManager, Map<Long, QueueBindingInfo> queueInfos, Map<SimpleString, List<Pair<byte[], Long>>> duplicateIDMap, Set<Pair<Long, Long>> pendingLargeMessages, Set<Long> storedLargeMessages, List<PageCountPending> pendingNonTXPageCounter, JournalLoader journalLoader, List<Consumer<RecordInfo>> extraLoaders) -
Uses of PageCountPending in org.apache.activemq.artemis.core.server.impl
Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type PageCountPendingModifier and TypeMethodDescriptionvoidJournalLoader.recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter) voidPostOfficeJournalLoader.recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter) This method will recover the counters after failures making sure the page counter doesn't get out of sync