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)

Method Summary

Modifier and Type	Method and Description
void	addQueue(org.apache.activemq.artemis.api.core.SimpleString address, Queue queue)
void	addQueueWithAck(org.apache.activemq.artemis.api.core.SimpleString address, Queue queue)
void	clear()
Map<org.apache.activemq.artemis.api.core.SimpleString,RouteContextList>	getContexListing()
RouteContextList	getContextListing(org.apache.activemq.artemis.api.core.SimpleString address)
List<Queue>	getDurableQueues(org.apache.activemq.artemis.api.core.SimpleString address)
List<Queue>	getNonDurableQueues(org.apache.activemq.artemis.api.core.SimpleString address)
int	getQueueCount()
Transaction	getTransaction()
boolean	isAlreadyAcked(org.apache.activemq.artemis.api.core.SimpleString address, Queue queue)
void	setTransaction(Transaction tx)

Methods inherited from class java.lang.Object

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

Constructor Detail

RoutingContextImpl

public RoutingContextImpl(Transaction transaction)

Method Detail

clear

public void clear()

Specified by:

clear in interface RoutingContext

addQueue

public void addQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                     Queue queue)

Specified by:

addQueue in interface RoutingContext

addQueueWithAck

public void addQueueWithAck(org.apache.activemq.artemis.api.core.SimpleString address,
                            Queue queue)

Specified by:

addQueueWithAck in interface RoutingContext

isAlreadyAcked

public boolean isAlreadyAcked(org.apache.activemq.artemis.api.core.SimpleString address,
                              Queue queue)

Specified by:

isAlreadyAcked in interface RoutingContext

getContextListing

public RouteContextList getContextListing(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.SimpleString address)

Specified by:

getNonDurableQueues in interface RoutingContext

getDurableQueues

public List<Queue> getDurableQueues(org.apache.activemq.artemis.api.core.SimpleString address)

Specified by:

getDurableQueues in interface RoutingContext

getQueueCount

public int getQueueCount()

Specified by:

getQueueCount in interface RoutingContext

getContexListing

public Map<org.apache.activemq.artemis.api.core.SimpleString,RouteContextList> getContexListing()

Specified by:

getContexListing in interface RoutingContext