org.apache.activemq.artemis.core.postoffice.impl

Class PostOfficeImpl

java.lang.Object

org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl

All Implemented Interfaces:

BindingsFactory, PostOffice, ActiveMQComponent, NotificationListener

public class PostOfficeImpl
extends Object
implements PostOffice, NotificationListener, BindingsFactory

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 * *

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PostOfficeImpl.AddOperation

Field Summary

Fields

Modifier and Type	Field and Description
static SimpleString	BRIDGE_CACHE_STR
static SimpleString	HDR_RESET_QUEUE_DATA
static SimpleString	HDR_RESET_QUEUE_DATA_COMPLETE

Constructor Summary

Constructors

Constructor and Description
PostOfficeImpl(ActiveMQServer server, StorageManager storageManager, PagingManager pagingManager, QueueFactory bindableFactory, ManagementService managementService, long reaperPeriod, int reaperPriority, boolean enableWildCardRouting, int idCacheSize, boolean persistIDCache, HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Summary

Modifier and Type	Method and Description
void	addBinding(Binding binding)
protected void	cleanupInternalPropertiesBeforeRouting(ServerMessage message)
Bindings	createBindings(SimpleString address)
Set<SimpleString>	getAddresses()
AddressManager	getAddressManager()
Map<SimpleString,Binding>	getAllBindings()
Binding	getBinding(SimpleString name)
Bindings	getBindingsForAddress(SimpleString address) Differently to lookupBindings, this will always create a new element on the Queue if non-existent
DuplicateIDCache	getDuplicateIDCache(SimpleString address)
ConcurrentMap<SimpleString,DuplicateIDCache>	getDuplicateIDCaches()
Bindings	getMatchingBindings(SimpleString address)
Object	getNotificationLock()
ActiveMQServer	getServer()
boolean	isAddressBound(SimpleString address)
boolean	isStarted()
Bindings	lookupBindingsForAddress(SimpleString address) It will lookup the Binding without creating an item on the Queue if non-existent
void	onNotification(Notification notification)
void	processRoute(ServerMessage message, RoutingContext context, boolean direct)
Pair<RoutingContext,ServerMessage>	redistribute(ServerMessage message, Queue originatingQueue, Transaction tx) The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
Binding	removeBinding(SimpleString uniqueName, Transaction tx, boolean deleteData)
MessageReference	reroute(ServerMessage message, Queue queue, Transaction tx)
RoutingStatus	route(ServerMessage message, QueueCreator queueCreator, boolean direct)
RoutingStatus	route(ServerMessage message, QueueCreator queueCreator, RoutingContext context, boolean direct)
RoutingStatus	route(ServerMessage message, QueueCreator queueCreator, RoutingContext context, boolean direct, boolean rejectDuplicates)
RoutingStatus	route(ServerMessage message, QueueCreator queueCreator, Transaction tx, boolean direct)
RoutingStatus	route(ServerMessage message, QueueCreator queueCreator, Transaction tx, boolean direct, boolean rejectDuplicates)
void	sendQueueInfoToQueue(SimpleString queueName, SimpleString address)
void	start()
void	startExpiryScanner() The expiry scanner can't be started until the whole server has been started other wise you may get races
void	stop()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

HDR_RESET_QUEUE_DATA

public static final SimpleString HDR_RESET_QUEUE_DATA

HDR_RESET_QUEUE_DATA_COMPLETE

public static final SimpleString HDR_RESET_QUEUE_DATA_COMPLETE

BRIDGE_CACHE_STR

public static final SimpleString BRIDGE_CACHE_STR

Constructor Detail

PostOfficeImpl

public PostOfficeImpl(ActiveMQServer server,
                      StorageManager storageManager,
                      PagingManager pagingManager,
                      QueueFactory bindableFactory,
                      ManagementService managementService,
                      long reaperPeriod,
                      int reaperPriority,
                      boolean enableWildCardRouting,
                      int idCacheSize,
                      boolean persistIDCache,
                      HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

onNotification

public void onNotification(Notification notification)

Specified by:

onNotification in interface NotificationListener

addBinding

public void addBinding(Binding binding)
                throws Exception

Specified by:

addBinding in interface PostOffice

Throws:

Exception

removeBinding

public Binding removeBinding(SimpleString uniqueName,
                             Transaction tx,
                             boolean deleteData)
                      throws Exception

Specified by:

removeBinding in interface PostOffice

Throws:

Exception

isAddressBound

public boolean isAddressBound(SimpleString address)
                       throws Exception

Specified by:

isAddressBound in interface PostOffice

Throws:

Exception

getBindingsForAddress

public Bindings getBindingsForAddress(SimpleString address)
                               throws Exception

Description copied from interface: PostOffice

Differently to lookupBindings, this will always create a new element on the Queue if non-existent

Specified by:

getBindingsForAddress in interface PostOffice

Throws:

Exception

lookupBindingsForAddress

public Bindings lookupBindingsForAddress(SimpleString address)
                                  throws Exception

Description copied from interface: PostOffice

It will lookup the Binding without creating an item on the Queue if non-existent

Specified by:

lookupBindingsForAddress in interface PostOffice

Throws:

Exception

getBinding

public Binding getBinding(SimpleString name)

Specified by:

getBinding in interface PostOffice

getMatchingBindings

public Bindings getMatchingBindings(SimpleString address)
                             throws Exception

Specified by:

getMatchingBindings in interface PostOffice

Throws:

Exception

getAllBindings

public Map<SimpleString,Binding> getAllBindings()

Specified by:

getAllBindings in interface PostOffice

route

public RoutingStatus route(ServerMessage message,
                           QueueCreator queueCreator,
                           boolean direct)
                    throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

public RoutingStatus route(ServerMessage message,
                           QueueCreator queueCreator,
                           Transaction tx,
                           boolean direct)
                    throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

public RoutingStatus route(ServerMessage message,
                           QueueCreator queueCreator,
                           Transaction tx,
                           boolean direct,
                           boolean rejectDuplicates)
                    throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

public RoutingStatus route(ServerMessage message,
                           QueueCreator queueCreator,
                           RoutingContext context,
                           boolean direct)
                    throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

public RoutingStatus route(ServerMessage message,
                           QueueCreator queueCreator,
                           RoutingContext context,
                           boolean direct,
                           boolean rejectDuplicates)
                    throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

reroute

public MessageReference reroute(ServerMessage message,
                                Queue queue,
                                Transaction tx)
                         throws Exception

Specified by:

reroute in interface PostOffice

Throws:

Exception

redistribute

public Pair<RoutingContext,ServerMessage> redistribute(ServerMessage message,
                                                       Queue originatingQueue,
                                                       Transaction tx)
                                                throws Exception

The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread

Specified by:

redistribute in interface PostOffice

Throws:

Exception

getDuplicateIDCache

public DuplicateIDCache getDuplicateIDCache(SimpleString address)

Specified by:

getDuplicateIDCache in interface PostOffice

getDuplicateIDCaches

public ConcurrentMap<SimpleString,DuplicateIDCache> getDuplicateIDCaches()

getNotificationLock

public Object getNotificationLock()

Specified by:

getNotificationLock in interface PostOffice

getAddresses

public Set<SimpleString> getAddresses()

Specified by:

getAddresses in interface PostOffice

sendQueueInfoToQueue

public void sendQueueInfoToQueue(SimpleString queueName,
                                 SimpleString address)
                          throws Exception

Specified by:

sendQueueInfoToQueue in interface PostOffice

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

cleanupInternalPropertiesBeforeRouting

protected void cleanupInternalPropertiesBeforeRouting(ServerMessage message)

Parameters:

message -

processRoute

public void processRoute(ServerMessage message,
                         RoutingContext context,
                         boolean direct)
                  throws Exception

Specified by:

processRoute in interface PostOffice

Throws:

Exception

startExpiryScanner

public void startExpiryScanner()

The expiry scanner can't be started until the whole server has been started other wise you may get races

Specified by:

startExpiryScanner in interface PostOffice

createBindings

public Bindings createBindings(SimpleString address)
                        throws Exception

Specified by:

createBindings in interface BindingsFactory

Throws:

Exception

getAddressManager

public AddressManager getAddressManager()

getServer

public ActiveMQServer getServer()