Package org.apache.activemq.artemis.core.server

Interface RoutingContext

All Known Implementing Classes:

RoutingContextImpl

public interface RoutingContext

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	RoutingContext.MirrorOption

Method Summary

Modifier and Type	Method	Description
void	addQueue(SimpleString address, Queue queue)
void	addQueueWithAck(SimpleString address, Queue queue)
RoutingContext	clear()
void	disableDivert()
void	forEachDurable(Consumer<Queue> consumer)
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)
RoutingContext	setDuplicateDetection(boolean value)
RoutingContext	setLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)
RoutingContext	setMirrorOption(RoutingContext.MirrorOption option)
RoutingContext	setMirrorSource(MirrorController mirrorController)
RoutingContext	setReusable(boolean reusable)
RoutingContext	setReusable(boolean reusable, int version)
RoutingContext	setRoutingType(RoutingType routingType)
RoutingContext	setServerSession(ServerSession session)
void	setTransaction(Transaction transaction)

Method Details

isReusable

boolean isReusable()

getMirrorOption

RoutingContext.MirrorOption getMirrorOption()

isDivertDisabled

boolean isDivertDisabled()

disableDivert

void disableDivert()

forEachDurable

void forEachDurable(Consumer<Queue> consumer)

setMirrorOption

RoutingContext setMirrorOption(RoutingContext.MirrorOption option)

isMirrorDisabled

boolean isMirrorDisabled()

isMirrorIndividualRoute

boolean isMirrorIndividualRoute()

isInternal

boolean isInternal()

return true if every queue routed is internal

getMirrorSource

MirrorController getMirrorSource()

setMirrorSource

RoutingContext setMirrorSource(MirrorController mirrorController)

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(Message message,
 Queue queue)

setAddress

void setAddress(SimpleString address)

setRoutingType

RoutingContext setRoutingType(RoutingType routingType)

getAddress

SimpleString getAddress(Message message)

getAddress

SimpleString getAddress()

getRoutingType

RoutingType getRoutingType()

getPreviousRoutingType

RoutingType getPreviousRoutingType()

isReusable

boolean isReusable(Message message,
 int version)

isDuplicateDetection

boolean isDuplicateDetection()

setDuplicateDetection

RoutingContext setDuplicateDetection(boolean value)

setLoadBalancingType

RoutingContext setLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)

getLoadBalancingType

MessageLoadBalancingType getLoadBalancingType()

setServerSession

RoutingContext setServerSession(ServerSession session)

getServerSession

ServerSession getServerSession()