Uses of Interface
org.apache.activemq.artemis.core.paging.PagingManager
Packages that use PagingManager
Package
Description
-
Uses of PagingManager in org.apache.activemq.artemis.cli.commands.tools
Fields in org.apache.activemq.artemis.cli.commands.tools declared as PagingManager -
Uses of PagingManager in org.apache.activemq.artemis.core.management.impl
Constructors in org.apache.activemq.artemis.core.management.impl with parameters of type PagingManagerModifierConstructorDescriptionAddressControlImpl(AddressInfo addressInfo, ActiveMQServer server, PagingManager pagingManager, StorageManager storageManager, HierarchicalRepository<Set<Role>> securityRepository, SecurityStore securityStore, ManagementService managementService) -
Uses of PagingManager in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return PagingManagerModifier and TypeMethodDescriptiondefault PagingManagerPagingManager.addSize(int size) An utility method to call addSize(size, false); this is a good fit for an IntConsumer.PagingManager.addSize(int size, boolean sizeOnly) Add size at the global count level.default PagingManagerPagingManager.addSizeOnly(int size) An utility method to call addSize(size, true); this is a good fit for an IntConsumer.PagingStore.getPagingManager()Methods in org.apache.activemq.artemis.core.paging with parameters of type PagingManagerModifier and TypeMethodDescriptionbooleanPageTransactionInfo.checkSize(StorageManager storageManager, PagingManager pagingManager) booleanPageTransactionInfo.onUpdate(int update, StorageManager storageManager, PagingManager pagingManager) voidPageTransactionInfo.reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) voidPagingStoreFactory.setPagingManager(PagingManager manager) voidPageTransactionInfo.store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) voidPageTransactionInfo.storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) -
Uses of PagingManager in org.apache.activemq.artemis.core.paging.cursor.impl
Constructors in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type PagingManagerModifierConstructorDescriptionPageCounterRebuildManager(PagingManager pagingManager, PagingStore store, Map<Long, PageTransactionInfo> transactions, Set<Long> storedLargeMessages, AtomicLong minPageTXIDFound) -
Uses of PagingManager in org.apache.activemq.artemis.core.paging.impl
Classes in org.apache.activemq.artemis.core.paging.impl that implement PagingManagerMethods in org.apache.activemq.artemis.core.paging.impl that return PagingManagerModifier and TypeMethodDescriptionPagingStoreFactoryNIO.getPagingManager()PagingStoreImpl.getPagingManager()Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type PagingManagerModifier and TypeMethodDescriptionbooleanPageTransactionInfoImpl.checkSize(StorageManager storageManager, PagingManager pagingManager) booleanPageTransactionInfoImpl.internalCheckSize(StorageManager storageManager, PagingManager pagingManager, int size) protected org.apache.activemq.artemis.core.paging.impl.PageTransactionInfoImpl.UpdatePageTXOperationPageTransactionInfoImpl.internalUpdatePageManager(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) booleanPageTransactionInfoImpl.onUpdate(int update, StorageManager storageManager, PagingManager pagingManager) voidPageTransactionInfoImpl.reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) voidPagingStoreFactoryDatabase.setPagingManager(PagingManager pagingManager) voidPagingStoreFactoryNIO.setPagingManager(PagingManager pagingManager) voidPageTransactionInfoImpl.store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) voidPageTransactionInfoImpl.storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) Constructors in org.apache.activemq.artemis.core.paging.impl with parameters of type PagingManagerModifierConstructorDescriptionPagingStoreImpl(SimpleString address, ScheduledExecutorService scheduledExecutor, long syncTimeout, PagingManager pagingManager, StorageManager storageManager, SequentialFileFactory fileFactory, PagingStoreFactory storeFactory, SimpleString storeName, AddressSettings addressSettings, ArtemisExecutor executor, boolean syncNonTransactional) -
Uses of PagingManager in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type PagingManagerModifier 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) voidStorageManager.startReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout) -
Uses of PagingManager in org.apache.activemq.artemis.core.persistence.impl.journal
Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type PagingManagerModifier and TypeMethodDescriptionvoidAbstractJournalStorageManager.checkInvalidPageTransactions(PagingManager pagingManager, Set<PageTransactionInfo> invalidPageTransactions) AbstractJournalStorageManager.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) voidJournalStorageManager.startReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout) -
Uses of PagingManager in org.apache.activemq.artemis.core.persistence.impl.nullpm
Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type PagingManagerModifier 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) voidNullStorageManager.startReplication(ReplicationManager replicationManager, PagingManager pagingManager, String nodeID, boolean autoFailBack, long initialReplicationSyncTimeout) -
Uses of PagingManager in org.apache.activemq.artemis.core.postoffice.impl
Constructors in org.apache.activemq.artemis.core.postoffice.impl with parameters of type PagingManagerModifierConstructorDescriptionPostOfficeImpl(ActiveMQServer server, StorageManager storageManager, PagingManager pagingManager, QueueFactory bindableFactory, ManagementService managementService, long expiryReaperPeriod, long addressQueueReaperPeriod, WildcardConfiguration wildcardConfiguration, int idCacheSize, boolean persistIDCache, HierarchicalRepository<AddressSettings> addressSettingsRepository) -
Uses of PagingManager in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return PagingManagerModifier and TypeMethodDescriptionActiveMQServer.createPagingManager()ActiveMQServer.getPagingManager()Methods in org.apache.activemq.artemis.core.server with parameters of type PagingManagerModifier and TypeMethodDescriptionQueueFactory.createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter) QueueConfig.Builder.pagingManager(PagingManager pagingManager) Deprecated. -
Uses of PagingManager in org.apache.activemq.artemis.core.server.impl
Fields in org.apache.activemq.artemis.core.server.impl declared as PagingManagerModifier and TypeFieldDescriptionprotected final PagingManagerPostOfficeJournalLoader.pagingManagerprotected final PagingManagerServerSessionImpl.pagingManagerMethods in org.apache.activemq.artemis.core.server.impl that return PagingManagerModifier and TypeMethodDescriptionActiveMQServerImpl.createPagingManager()ActiveMQServerImpl.getPagingManager()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type PagingManagerModifier 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) QueueFactoryImpl.createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter) static PageSubscriptionQueueFactoryImpl.getPageSubscription(QueueConfiguration queueConfiguration, PagingManager pagingManager, Filter filter) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type PagingManagerModifierConstructorDescriptionBackupRecoveryJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer, ServerLocatorInternal locator, ClusterController clusterController) PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration) PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, Map<Long, Queue> queues) ScaleDownHandler(PagingManager pagingManager, PostOffice postOffice, NodeManager nodeManager, ClusterController clusterController, StorageManager storageManager, int commitInterval) ServerInfo(ActiveMQServer server, PagingManager pagingManager) ServerSessionImpl(String name, String username, String password, String validatedUser, int minLargeMessageSize, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean strictUpdateDeliveryCount, boolean xa, RemotingConnection remotingConnection, StorageManager storageManager, PostOffice postOffice, ResourceManager resourceManager, SecurityStore securityStore, ManagementService managementService, ActiveMQServer server, SimpleString managementAddress, SimpleString defaultAddress, SessionCallback callback, OperationContext context, PagingManager pagingManager, Map<SimpleString, RoutingType> prefixes, String securityDomain, boolean isLegacyProducer) -
Uses of PagingManager in org.apache.activemq.artemis.core.server.management
Methods in org.apache.activemq.artemis.core.server.management with parameters of type PagingManagerModifier and TypeMethodDescriptionManagementService.registerServer(PostOffice postOffice, SecurityStore securityStore, StorageManager storageManager, Configuration configuration, HierarchicalRepository<AddressSettings> addressSettingsRepository, HierarchicalRepository<Set<Role>> securityRepository, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, QueueFactory queueFactory, ScheduledExecutorService scheduledThreadPool, PagingManager pagingManager, boolean backup) -
Uses of PagingManager in org.apache.activemq.artemis.core.server.management.impl
Methods in org.apache.activemq.artemis.core.server.management.impl with parameters of type PagingManagerModifier and TypeMethodDescriptionManagementServiceImpl.registerServer(PostOffice postOffice, SecurityStore securityStore, StorageManager storageManager1, Configuration configuration, HierarchicalRepository<AddressSettings> addressSettingsRepository, HierarchicalRepository<Set<Role>> securityRepository, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, QueueFactory queueFactory, ScheduledExecutorService scheduledThreadPool, PagingManager pagingManager, boolean backup)