org.hornetq.core.postoffice.impl

Class PostOfficeImpl

java.lang.Object

org.hornetq.core.postoffice.impl.PostOfficeImpl

All Implemented Interfaces:

BindingsFactory, PostOffice, HornetQComponent, NotificationListener

public class PostOfficeImpl
extends Object
implements PostOffice, NotificationListener, BindingsFactory

A PostOfficeImpl

Author:

Tim Fox, Jeff Mesnil, Clebert Suconic

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	addBinding(Binding binding)
protected void	cleanupInternalPropertiesBeforeRouting(ServerMessage message)
Bindings	createBindings(SimpleString address)
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)
Bindings	getMatchingBindings(SimpleString address)
Object	getNotificationLock()
PagingManager	getPagingManager()
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)
MessageReference	reroute(ServerMessage message, Queue queue, Transaction tx)
void	route(ServerMessage message, boolean direct)
void	route(ServerMessage message, RoutingContext context, boolean direct)
void	route(ServerMessage message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	route(ServerMessage message, Transaction tx, boolean direct)
void	route(ServerMessage message, Transaction tx, boolean direct, boolean rejectDuplicates)
void	sendQueueInfoToQueue(SimpleString queueName, SimpleString address)
void	start()
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

BRIDGE_CACHE_STR

public static final SimpleString BRIDGE_CACHE_STR

Constructor Detail

PostOfficeImpl

public PostOfficeImpl(HornetQServer 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 HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

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)
                      throws Exception

Specified by:

removeBinding 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

Returns:

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

Returns:

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

route

public void route(ServerMessage message,
         boolean direct)
           throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

public void route(ServerMessage message,
         Transaction tx,
         boolean direct)
           throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

public void route(ServerMessage message,
         Transaction tx,
         boolean direct,
         boolean rejectDuplicates)
           throws Exception

Specified by:

route in interface PostOffice

Throws:

Exception

route

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

Specified by:

route in interface PostOffice

Throws:

Exception

route

public void route(ServerMessage message,
         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

getPagingManager

public PagingManager getPagingManager()

Specified by:

getPagingManager in interface PostOffice

getDuplicateIDCache

public DuplicateIDCache getDuplicateIDCache(SimpleString address)

Specified by:

getDuplicateIDCache in interface PostOffice

getNotificationLock

public Object getNotificationLock()

Specified by:

getNotificationLock 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

createBindings

public Bindings createBindings(SimpleString address)
                        throws Exception

Specified by:

createBindings in interface BindingsFactory

Throws:

Exception