Uses of Interface
org.apache.activemq.artemis.core.postoffice.PostOffice
Packages that use PostOffice
Package
Description
-
Uses of PostOffice in org.apache.activemq.artemis.core.management.impl
Constructors in org.apache.activemq.artemis.core.management.impl with parameters of type PostOfficeModifierConstructorDescriptionActiveMQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster) -
Uses of PostOffice in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type PostOfficeModifier 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 PostOffice in org.apache.activemq.artemis.core.persistence.impl.journal
Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type PostOfficeModifier 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 PostOffice in org.apache.activemq.artemis.core.persistence.impl.nullpm
Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type PostOfficeModifier 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 PostOffice in org.apache.activemq.artemis.core.postoffice
Methods in org.apache.activemq.artemis.core.postoffice that return PostOfficeModifier and TypeMethodDescriptionPostOffice.setMirrorControlSource(MirrorController mirrorControllerSource) -
Uses of PostOffice in org.apache.activemq.artemis.core.postoffice.impl
Classes in org.apache.activemq.artemis.core.postoffice.impl that implement PostOfficeModifier and TypeClassDescriptionclassThis is the class that will make the routing to Queues and decide which consumer will get the messages It's the queue component on distributing the messages * * -
Uses of PostOffice in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return PostOfficeMethods in org.apache.activemq.artemis.core.server with parameters of type PostOfficeModifier and TypeMethodDescriptionConnectorServiceFactory.createConnectorService(String connectorName, Map<String, Object> configuration, StorageManager storageManager, PostOffice postOffice, ScheduledExecutorService scheduledThreadPool) voidQueueFactory.setPostOffice(PostOffice postOffice) This is required for delete-all-reference to work correctly with paging -
Uses of PostOffice in org.apache.activemq.artemis.core.server.cluster
Constructors in org.apache.activemq.artemis.core.server.cluster with parameters of type PostOfficeModifierConstructorDescriptionClusterManager(ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean useQuorumManager) -
Uses of PostOffice in org.apache.activemq.artemis.core.server.cluster.impl
Constructors in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type PostOfficeModifierConstructorDescriptionClusterConnectionImpl(ClusterManager manager, DiscoveryGroupConfiguration dg, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts, String clientId, int topologyScannerAttempts) ClusterConnectionImpl(ClusterManager manager, TransportConfiguration[] staticTranspConfigs, TransportConfiguration connector, SimpleString name, SimpleString address, int minLargeMessageSize, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, long maxRetryInterval, int initialConnectAttempts, int reconnectAttempts, long callTimeout, long callFailoverTimeout, boolean useDuplicateDetection, MessageLoadBalancingType messageLoadBalancingType, int confirmationWindowSize, int producerWindowSize, ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ManagementService managementService, ScheduledExecutorService scheduledExecutor, int maxHops, NodeManager nodeManager, String clusterUser, String clusterPassword, boolean allowDirectConnectionsOnly, long clusterNotificationInterval, int clusterNotificationAttempts, String clientId, int topologyScannerAttempts) Redistributor(Queue queue, long sequentialID, PostOffice postOffice) -
Uses of PostOffice in org.apache.activemq.artemis.core.server.impl
Fields in org.apache.activemq.artemis.core.server.impl declared as PostOfficeModifier and TypeFieldDescriptionprotected final PostOfficePostOfficeJournalLoader.postOfficeprotected PostOfficeQueueFactoryImpl.postOfficeThis is required for delete-all-reference to work correctly with paging, and controlling global-sizefinal PostOfficeServerSessionImpl.postOfficeMethods in org.apache.activemq.artemis.core.server.impl that return PostOfficeMethods in org.apache.activemq.artemis.core.server.impl with parameters of type PostOfficeModifier 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) voidAddressInfo.setPostOffice(PostOffice postOffice) voidQueueFactoryImpl.setPostOffice(PostOffice postOffice) Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type PostOfficeModifierConstructorDescriptionBackupRecoveryJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer, ServerLocatorInternal locator, ClusterController clusterController) ConnectorsService(Configuration configuration, StorageManager storageManager, ScheduledExecutorService scheduledPool, PostOffice postOffice, ServiceRegistry serviceRegistry) DivertImpl(SimpleString uniqueName, SimpleString address, SimpleString forwardAddress, SimpleString routingName, boolean exclusive, Filter filter, Transformer transformer, PostOffice postOffice, StorageManager storageManager, ComponentConfigurationRoutingType routingType) LastValueQueue(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) 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) QueueImpl(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) ScaleDownHandler(PagingManager pagingManager, PostOffice postOffice, NodeManager nodeManager, ClusterController clusterController, StorageManager storageManager, int commitInterval) 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 PostOffice in org.apache.activemq.artemis.core.server.management
Methods in org.apache.activemq.artemis.core.server.management with parameters of type PostOfficeModifier 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 PostOffice in org.apache.activemq.artemis.core.server.management.impl
Methods in org.apache.activemq.artemis.core.server.management.impl with parameters of type PostOfficeModifier 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)