Package 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 class RoutingContextImpl
extends Object
implements RoutingContext

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RoutingContextImpl.ContextListing

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.server.RoutingContext

RoutingContext.MirrorOption

Constructor Summary

Constructors

Constructor	Description
RoutingContextImpl(Transaction transaction)

Method Summary

Modifier and Type	Method	Description
void	addQueue(SimpleString address, Queue queue)
void	addQueueWithAck(SimpleString address, Queue queue)
RoutingContextImpl	clear()
void	disableDivert()
void	forEachDurable(Consumer<Queue> queueConsumer)
SimpleString	getAddress()
SimpleString	getAddress(Message message)
Map<SimpleString,RouteContextList>	getContexListing()
RouteContextList	getContextListing(SimpleString address)
List<Queue>	getDurableQueues(SimpleString address)
MessageLoadBalancingType	getLoadBalancingType()
RoutingContext.MirrorOption	getMirrorOption()
MirrorController	getMirrorSource()
List<Queue>	getNonDurableQueues(SimpleString address)
SimpleString	getPreviousAddress()
int	getPreviousBindingsVersion()
RoutingType	getPreviousRoutingType()
int	getQueueCount()
RoutingType	getRoutingType()
ServerSession	getServerSession()
Transaction	getTransaction()
boolean	isAlreadyAcked(Message message, Queue queue)
boolean	isDivertDisabled()
boolean	isDuplicateDetection()
boolean	isInternal()	return true if every queue routed is internal
boolean	isMirrorDisabled()
boolean	isMirrorIndividualRoute()
boolean	isReusable()
boolean	isReusable(Message message, int version)
void	setAddress(SimpleString address)
RoutingContextImpl	setDuplicateDetection(boolean value)
RoutingContextImpl	setLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)
RoutingContextImpl	setMirrorOption(RoutingContext.MirrorOption mirrorOption)
RoutingContext	setMirrorSource(MirrorController mirrorController)
RoutingContextImpl	setReusable(boolean reusable)
RoutingContextImpl	setReusable(boolean reusable, int previousBindings)
RoutingContextImpl	setRoutingType(RoutingType routingType)
RoutingContextImpl	setServerSession(ServerSession session)
void	setTransaction(Transaction tx)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

RoutingContextImpl

public RoutingContextImpl(Transaction transaction)

Method Details

isDuplicateDetection

public boolean isDuplicateDetection()

Specified by:

isDuplicateDetection in interface RoutingContext

setDuplicateDetection

public RoutingContextImpl setDuplicateDetection(boolean value)

Specified by:

setDuplicateDetection in interface RoutingContext

getMirrorOption

public RoutingContext.MirrorOption getMirrorOption()

Specified by:

getMirrorOption in interface RoutingContext

isDivertDisabled

public boolean isDivertDisabled()

Specified by:

isDivertDisabled in interface RoutingContext

disableDivert

public void disableDivert()

Specified by:

disableDivert in interface RoutingContext

isMirrorDisabled

public boolean isMirrorDisabled()

Specified by:

isMirrorDisabled in interface RoutingContext

forEachDurable

public void forEachDurable(Consumer<Queue> queueConsumer)

Specified by:

forEachDurable in interface RoutingContext

isMirrorIndividualRoute

public boolean isMirrorIndividualRoute()

Specified by:

isMirrorIndividualRoute in interface RoutingContext

setMirrorOption

public RoutingContextImpl setMirrorOption(RoutingContext.MirrorOption mirrorOption)

Specified by:

setMirrorOption in interface RoutingContext

isReusable

public boolean isReusable()

Specified by:

isReusable in interface RoutingContext

isInternal

public boolean isInternal()

Description copied from interface: RoutingContext

return true if every queue routed is internal

Specified by:

isInternal 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 RoutingContextImpl setReusable(boolean reusable)

Specified by:

setReusable in interface RoutingContext

setReusable

public RoutingContextImpl setReusable(boolean reusable,
 int previousBindings)

Specified by:

setReusable in interface RoutingContext

clear

public RoutingContextImpl clear()

Specified by:

clear in interface RoutingContext

getMirrorSource

public MirrorController getMirrorSource()

Specified by:

getMirrorSource in interface RoutingContext

setMirrorSource

public RoutingContext setMirrorSource(MirrorController mirrorController)

Specified by:

setMirrorSource 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

setLoadBalancingType

public RoutingContextImpl setLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)

Specified by:

setLoadBalancingType in interface RoutingContext

getLoadBalancingType

public MessageLoadBalancingType getLoadBalancingType()

Specified by:

getLoadBalancingType in interface RoutingContext

addQueueWithAck

public void addQueueWithAck(SimpleString address,
 Queue queue)

Specified by:

addQueueWithAck in interface RoutingContext

isAlreadyAcked

public boolean isAlreadyAcked(Message message,
 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 RoutingContextImpl 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

setServerSession

public RoutingContextImpl setServerSession(ServerSession session)

Specified by:

setServerSession in interface RoutingContext

getServerSession

public ServerSession getServerSession()

Specified by:

getServerSession 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