org.hornetq.core.postoffice

Interface PostOffice

All Superinterfaces:

HornetQComponent

All Known Implementing Classes:

PostOfficeImpl

public interface PostOffice
extends HornetQComponent

A PostOffice instance maintains a mapping of a String address to a Queue. Multiple Queue instances can be bound with the same String address. Given a message and an address a PostOffice instance will route that message to all the Queue instances that are registered with that address. Addresses can be any String instance. A Queue instance can only be bound against a single address in the post office.

Author:

Tim Fox

Method Summary

Methods

Modifier and Type	Method and Description
void	addBinding(Binding binding)
Binding	getBinding(SimpleString uniqueName)
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()
Bindings	lookupBindingsForAddress(SimpleString address) It will lookup the Binding without creating an item on the Queue if non-existent
void	processRoute(ServerMessage message, RoutingContext context, boolean direct)
Pair<RoutingContext,ServerMessage>	redistribute(ServerMessage message, Queue originatingQueue, Transaction tx)
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)

Methods inherited from interface org.hornetq.core.server.HornetQComponent

isStarted, start, stop

Method Detail

addBinding

void addBinding(Binding binding)
                throws Exception

Throws:

Exception

removeBinding

Binding removeBinding(SimpleString uniqueName)
                      throws Exception

Throws:

Exception

lookupBindingsForAddress

Bindings lookupBindingsForAddress(SimpleString address)
                                  throws Exception

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

Parameters:

address -

Returns:

Throws:

Exception

getBindingsForAddress

Bindings getBindingsForAddress(SimpleString address)
                               throws Exception

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

Parameters:

address -

Returns:

Throws:

Exception

getBinding

Binding getBinding(SimpleString uniqueName)

getMatchingBindings

Bindings getMatchingBindings(SimpleString address)
                             throws Exception

Throws:

Exception

route

void route(ServerMessage message,
         boolean direct)
           throws Exception

Throws:

Exception

route

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

Throws:

Exception

route

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

Throws:

Exception

route

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

Throws:

Exception

route

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

Throws:

Exception

reroute

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

Throws:

Exception

redistribute

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

Throws:

Exception

processRoute

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

Throws:

Exception

getPagingManager

PagingManager getPagingManager()

getDuplicateIDCache

DuplicateIDCache getDuplicateIDCache(SimpleString address)

sendQueueInfoToQueue

void sendQueueInfoToQueue(SimpleString queueName,
                        SimpleString address)
                          throws Exception

Throws:

Exception

getNotificationLock

Object getNotificationLock()