org.apache.activemq.artemis.core.server.impl

Class RoutingContextImpl

java.lang.Object

org.apache.activemq.artemis.core.server.impl.RoutingContextImpl

All Implemented Interfaces:

RoutingContext

public final class RoutingContextImpl
extends Object
implements RoutingContext

Constructor Summary

Constructors

Constructor and Description
RoutingContextImpl(Transaction transaction)
RoutingContextImpl(Transaction transaction, Executor executor)

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 previousBindings)
void	setRoutingType(RoutingType routingType)
void	setTransaction(Transaction tx)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RoutingContextImpl

public RoutingContextImpl(Transaction transaction)

RoutingContextImpl

public RoutingContextImpl(Transaction transaction,
                          Executor executor)

Method Detail

isReusable

public boolean isReusable()

Specified by:

isReusable in interface RoutingContext

getPreviousBindingsVersion

public int getPreviousBindingsVersion()

Specified by:

getPreviousBindingsVersion in interface RoutingContext

getPreviousAddress

public SimpleString getPreviousAddress()

Specified by:

getPreviousAddress in interface RoutingContext

setReusable

public RoutingContext setReusable(boolean reusable)

Specified by:

setReusable in interface RoutingContext

setReusable

public RoutingContext setReusable(boolean reusable,
                                  int previousBindings)

Specified by:

setReusable in interface RoutingContext

clear

public RoutingContext clear()

Specified by:

clear in interface RoutingContext

addQueue

public void addQueue(SimpleString address,
                     Queue queue)

Specified by:

addQueue in interface RoutingContext

toString

public String toString()

Overrides:

toString in class Object

processReferences

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

Specified by:

processReferences in interface RoutingContext

addQueueWithAck

public void addQueueWithAck(SimpleString address,
                            Queue queue)

Specified by:

addQueueWithAck in interface RoutingContext

isAlreadyAcked

public boolean isAlreadyAcked(SimpleString address,
                              Queue queue)

Specified by:

isAlreadyAcked in interface RoutingContext

isReusable

public boolean isReusable(Message message,
                          int version)

Specified by:

isReusable in interface RoutingContext

setAddress

public void setAddress(SimpleString address)

Specified by:

setAddress in interface RoutingContext

setRoutingType

public void setRoutingType(RoutingType routingType)

Specified by:

setRoutingType in interface RoutingContext

getAddress

public SimpleString getAddress(Message message)

Specified by:

getAddress in interface RoutingContext

getAddress

public SimpleString getAddress()

Specified by:

getAddress in interface RoutingContext

getRoutingType

public RoutingType getRoutingType()

Specified by:

getRoutingType in interface RoutingContext

getPreviousRoutingType

public RoutingType getPreviousRoutingType()

Specified by:

getPreviousRoutingType in interface RoutingContext

getContextListing

public RouteContextList getContextListing(SimpleString address)

Specified by:

getContextListing in interface RoutingContext

getTransaction

public Transaction getTransaction()

Specified by:

getTransaction in interface RoutingContext

setTransaction

public void setTransaction(Transaction tx)

Specified by:

setTransaction in interface RoutingContext

getNonDurableQueues

public List<Queue> getNonDurableQueues(SimpleString address)

Specified by:

getNonDurableQueues in interface RoutingContext

getDurableQueues

public List<Queue> getDurableQueues(SimpleString address)

Specified by:

getDurableQueues in interface RoutingContext

getQueueCount

public int getQueueCount()

Specified by:

getQueueCount in interface RoutingContext

getContexListing

public Map<SimpleString,RouteContextList> getContexListing()

Specified by:

getContexListing in interface RoutingContext