public final class RoutingContextImpl extends Object implements RoutingContext
| Constructor and Description |
|---|
RoutingContextImpl(Transaction transaction) |
RoutingContextImpl(Transaction transaction,
Executor executor) |
public RoutingContextImpl(Transaction transaction)
public RoutingContextImpl(Transaction transaction, Executor executor)
public boolean isReusable()
isReusable in interface RoutingContextpublic int getPreviousBindingsVersion()
getPreviousBindingsVersion in interface RoutingContextpublic SimpleString getPreviousAddress()
getPreviousAddress in interface RoutingContextpublic RoutingContext setReusable(boolean reusable)
setReusable in interface RoutingContextpublic RoutingContext setReusable(boolean reusable, int previousBindings)
setReusable in interface RoutingContextpublic RoutingContext clear()
clear in interface RoutingContextpublic void addQueue(SimpleString address, Queue queue)
addQueue in interface RoutingContextpublic void processReferences(List<MessageReference> refs, boolean direct)
processReferences in interface RoutingContextpublic void addQueueWithAck(SimpleString address, Queue queue)
addQueueWithAck in interface RoutingContextpublic boolean isAlreadyAcked(SimpleString address, Queue queue)
isAlreadyAcked in interface RoutingContextpublic boolean isReusable(Message message, int version)
isReusable in interface RoutingContextpublic void setAddress(SimpleString address)
setAddress in interface RoutingContextpublic void setRoutingType(RoutingType routingType)
setRoutingType in interface RoutingContextpublic SimpleString getAddress(Message message)
getAddress in interface RoutingContextpublic SimpleString getAddress()
getAddress in interface RoutingContextpublic RoutingType getRoutingType()
getRoutingType in interface RoutingContextpublic RoutingType getPreviousRoutingType()
getPreviousRoutingType in interface RoutingContextpublic RouteContextList getContextListing(SimpleString address)
getContextListing in interface RoutingContextpublic Transaction getTransaction()
getTransaction in interface RoutingContextpublic void setTransaction(Transaction tx)
setTransaction in interface RoutingContextpublic List<Queue> getNonDurableQueues(SimpleString address)
getNonDurableQueues in interface RoutingContextpublic List<Queue> getDurableQueues(SimpleString address)
getDurableQueues in interface RoutingContextpublic int getQueueCount()
getQueueCount in interface RoutingContextpublic Map<SimpleString,RouteContextList> getContexListing()
getContexListing in interface RoutingContextCopyright © 2019 JBoss by Red Hat. All rights reserved.