Uses of Interface
org.apache.activemq.artemis.core.postoffice.PostOffice

Packages that use PostOffice

Package	Description
org.apache.activemq.artemis.core.management.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.nullpm
org.apache.activemq.artemis.core.postoffice.impl
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.server.management
org.apache.activemq.artemis.core.server.management.impl

Uses of PostOffice in org.apache.activemq.artemis.core.management.impl

Constructors in org.apache.activemq.artemis.core.management.impl with parameters of type PostOffice

Constructor and Description
ActiveMQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, ActiveMQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster)
AddressControlImpl(AddressInfo addressInfo, PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, HierarchicalRepository<Set<Role>> securityRepository, SecurityStore securityStore, ManagementService managementService)
QueueControlImpl(Queue queue, String address, PostOffice postOffice, StorageManager storageManager, SecurityStore securityStore, HierarchicalRepository<AddressSettings> addressSettingsRepository)

Uses of PostOffice in org.apache.activemq.artemis.core.persistence

Methods in org.apache.activemq.artemis.core.persistence with parameters of type PostOffice

Modifier and Type	Method and Description
JournalLoadInformation	StorageManager.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)

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 PostOffice

Modifier and Type	Method and Description
JournalLoadInformation	AbstractJournalStorageManager.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)

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 PostOffice

Modifier and Type	Method and Description
JournalLoadInformation	NullStorageManager.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)

Uses of PostOffice in org.apache.activemq.artemis.core.postoffice.impl

Classes in org.apache.activemq.artemis.core.postoffice.impl that implement PostOffice

Modifier and Type	Class and Description
class	PostOfficeImpl This 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 PostOffice

Modifier and Type	Method and Description
PostOffice	ActiveMQServer.getPostOffice()

Methods in org.apache.activemq.artemis.core.server with parameters of type PostOffice

Modifier and Type	Method and Description
ConnectorService	ConnectorServiceFactory.createConnectorService(String connectorName, Map<String,Object> configuration, StorageManager storageManager, PostOffice postOffice, ScheduledExecutorService scheduledThreadPool)
void	QueueFactory.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 PostOffice

Constructor and Description
ClusterManager(ExecutorFactory executorFactory, ActiveMQServer server, PostOffice postOffice, ScheduledExecutorService scheduledExecutor, ManagementService managementService, Configuration configuration, NodeManager nodeManager, boolean backup)

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 PostOffice

Constructor and Description
ClusterConnectionImpl(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)
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)
Redistributor(Queue queue, StorageManager storageManager, PostOffice postOffice, Executor executor, int batchSize)

Uses of PostOffice in org.apache.activemq.artemis.core.server.impl

Fields in org.apache.activemq.artemis.core.server.impl declared as PostOffice

Modifier and Type	Field and Description
PostOffice	ServerSessionImpl.postOffice
protected PostOffice	QueueFactoryImpl.postOffice This is required for delete-all-reference to work correctly with paging, and controlling global-size
protected PostOffice	PostOfficeJournalLoader.postOffice

Methods in org.apache.activemq.artemis.core.server.impl that return PostOffice

Modifier and Type	Method and Description
PostOffice	ActiveMQServerImpl.getPostOffice()

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type PostOffice

Modifier and Type	Method and Description
JournalLoader	SharedStoreBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)
JournalLoader	SharedNothingBackupActivation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)
JournalLoader	Activation.createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)
void	QueueFactoryImpl.setPostOffice(PostOffice postOffice)

Constructors in org.apache.activemq.artemis.core.server.impl with parameters of type PostOffice

Constructor and Description
BackupRecoveryJournalLoader(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 forwardAddress, SimpleString uniqueName, SimpleString routingName, boolean exclusive, Filter filter, Transformer transformer, PostOffice postOffice, StorageManager storageManager, DivertConfigurationRoutingType routingType)
LastValueQueue(long persistenceID, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean purgeOnNoConsumers, 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(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean exclusive, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, 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)
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)

Uses of PostOffice in org.apache.activemq.artemis.core.server.management

Methods in org.apache.activemq.artemis.core.server.management with parameters of type PostOffice

Modifier and Type

Method and Description

ActiveMQServerControlImpl

ManagementService.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 PostOffice

Modifier and Type

Method and Description

ActiveMQServerControlImpl

ManagementServiceImpl.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)