public final class RoutingContextImpl extends Object implements RoutingContext
Constructor and Description |
---|
RoutingContextImpl(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
void |
addQueue(SimpleString address,
Queue queue) |
void |
addQueueWithAck(SimpleString address,
Queue queue) |
void |
clear() |
SimpleString |
getAddress(Message message) |
Map<SimpleString,RouteContextList> |
getContexListing() |
RouteContextList |
getContextListing(SimpleString address) |
List<Queue> |
getDurableQueues(SimpleString address) |
List<Queue> |
getNonDurableQueues(SimpleString address) |
int |
getQueueCount() |
RoutingType |
getRoutingType() |
Transaction |
getTransaction() |
boolean |
isAlreadyAcked(SimpleString address,
Queue queue) |
void |
setAddress(SimpleString address) |
void |
setRoutingType(RoutingType routingType) |
void |
setTransaction(Transaction tx) |
public RoutingContextImpl(Transaction transaction)
public void clear()
clear
in interface RoutingContext
public void addQueue(SimpleString address, Queue queue)
addQueue
in interface RoutingContext
public void addQueueWithAck(SimpleString address, Queue queue)
addQueueWithAck
in interface RoutingContext
public boolean isAlreadyAcked(SimpleString address, Queue queue)
isAlreadyAcked
in interface RoutingContext
public void setAddress(SimpleString address)
setAddress
in interface RoutingContext
public void setRoutingType(RoutingType routingType)
setRoutingType
in interface RoutingContext
public SimpleString getAddress(Message message)
getAddress
in interface RoutingContext
public RoutingType getRoutingType()
getRoutingType
in interface RoutingContext
public RouteContextList getContextListing(SimpleString address)
getContextListing
in interface RoutingContext
public Transaction getTransaction()
getTransaction
in interface RoutingContext
public void setTransaction(Transaction tx)
setTransaction
in interface RoutingContext
public List<Queue> getNonDurableQueues(SimpleString address)
getNonDurableQueues
in interface RoutingContext
public List<Queue> getDurableQueues(SimpleString address)
getDurableQueues
in interface RoutingContext
public int getQueueCount()
getQueueCount
in interface RoutingContext
public Map<SimpleString,RouteContextList> getContexListing()
getContexListing
in interface RoutingContext
Copyright © 2018 JBoss by Red Hat. All rights reserved.