public interface PostOffice extends HornetQComponent
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() |
boolean |
isAddressBound(SimpleString address) |
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,
Transaction tx) |
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 |
startExpiryScanner() |
isStarted, start, stop
Binding removeBinding(SimpleString uniqueName, Transaction tx) throws Exception
Exception
Bindings lookupBindingsForAddress(SimpleString address) throws Exception
address
- Exception
Bindings getBindingsForAddress(SimpleString address) throws Exception
address
- Exception
Binding getBinding(SimpleString uniqueName)
Bindings getMatchingBindings(SimpleString address) throws Exception
Exception
void route(ServerMessage message, boolean direct) throws Exception
Exception
void route(ServerMessage message, Transaction tx, boolean direct) throws Exception
Exception
void route(ServerMessage message, Transaction tx, boolean direct, boolean rejectDuplicates) throws Exception
Exception
void route(ServerMessage message, RoutingContext context, boolean direct) throws Exception
Exception
void route(ServerMessage message, RoutingContext context, boolean direct, boolean rejectDuplicates) throws Exception
Exception
MessageReference reroute(ServerMessage message, Queue queue, Transaction tx) throws Exception
Exception
Pair<RoutingContext,ServerMessage> redistribute(ServerMessage message, Queue originatingQueue, Transaction tx) throws Exception
Exception
void processRoute(ServerMessage message, RoutingContext context, boolean direct) throws Exception
Exception
DuplicateIDCache getDuplicateIDCache(SimpleString address)
void sendQueueInfoToQueue(SimpleString queueName, SimpleString address) throws Exception
Exception
Object getNotificationLock()
void startExpiryScanner()
boolean isAddressBound(SimpleString address) throws Exception
Exception
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.