org.apache.activemq.artemis.core.server

Interface RoutingContext

All Known Implementing Classes:

RoutingContextImpl

public interface RoutingContext

Method Summary

Modifier and Type	Method and Description
void	addQueue(SimpleString address, Queue queue)
void	addQueueWithAck(SimpleString address, Queue queue)
RoutingContext	clear()
SimpleString	getAddress()
SimpleString	getAddress(Message message)
Map<SimpleString,RouteContextList>	getContexListing()
RouteContextList	getContextListing(SimpleString address)
List<Queue>	getDurableQueues(SimpleString address)
List<Queue>	getNonDurableQueues(SimpleString address)
SimpleString	getPreviousAddress()
int	getPreviousBindingsVersion()
RoutingType	getPreviousRoutingType()
int	getQueueCount()
RoutingType	getRoutingType()
Transaction	getTransaction()
boolean	isAlreadyAcked(SimpleString address, Queue queue)
boolean	isReusable()
boolean	isReusable(Message message, int version)
void	processReferences(List<MessageReference> refs, boolean direct)
void	setAddress(SimpleString address)
RoutingContext	setReusable(boolean reusable)
RoutingContext	setReusable(boolean reusable, int version)
void	setRoutingType(RoutingType routingType)
void	setTransaction(Transaction transaction)

Method Detail

isReusable

boolean isReusable()

getPreviousBindingsVersion

int getPreviousBindingsVersion()

getPreviousAddress

SimpleString getPreviousAddress()

setReusable

RoutingContext setReusable(boolean reusable)

setReusable

RoutingContext setReusable(boolean reusable,
                           int version)

getTransaction

Transaction getTransaction()

setTransaction

void setTransaction(Transaction transaction)

addQueue

void addQueue(SimpleString address,
              Queue queue)

getContexListing

Map<SimpleString,RouteContextList> getContexListing()

getContextListing

RouteContextList getContextListing(SimpleString address)

getNonDurableQueues

List<Queue> getNonDurableQueues(SimpleString address)

getDurableQueues

List<Queue> getDurableQueues(SimpleString address)

getQueueCount

int getQueueCount()

clear

RoutingContext clear()

addQueueWithAck

void addQueueWithAck(SimpleString address,
                     Queue queue)

isAlreadyAcked

boolean isAlreadyAcked(SimpleString address,
                       Queue queue)

setAddress

void setAddress(SimpleString address)

setRoutingType

void setRoutingType(RoutingType routingType)

getAddress

SimpleString getAddress(Message message)

getAddress

SimpleString getAddress()

getRoutingType

RoutingType getRoutingType()

getPreviousRoutingType

RoutingType getPreviousRoutingType()

processReferences

void processReferences(List<MessageReference> refs,
                       boolean direct)

isReusable

boolean isReusable(Message message,
                   int version)