Uses of Interface
org.apache.activemq.artemis.core.server.impl.JournalLoader
Packages that use JournalLoader
Package
Description
-
Uses of JournalLoader in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type JournalLoaderModifier 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 JournalLoader in org.apache.activemq.artemis.core.persistence.impl.journal
Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type JournalLoaderModifier 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 JournalLoader in org.apache.activemq.artemis.core.persistence.impl.nullpm
Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type JournalLoaderModifier 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 JournalLoader in org.apache.activemq.artemis.core.server.impl
Classes in org.apache.activemq.artemis.core.server.impl that implement JournalLoaderModifier and TypeClassDescriptionclassInstead of loading into its own post office this will use its parent server (the active server) and load into that.classMethods in org.apache.activemq.artemis.core.server.impl that return JournalLoaderModifier and TypeMethodDescriptionActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) create the Journal loader needed for this Activation.SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer) SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)