Uses of Interface
org.apache.activemq.artemis.core.server.Consumer

Packages that use Consumer

Package	Description
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl

Uses of Consumer in org.apache.activemq.artemis.core.server

Subinterfaces of Consumer in org.apache.activemq.artemis.core.server

Modifier and Type	Interface and Description
interface	ServerConsumer A ServerConsumer

Methods in org.apache.activemq.artemis.core.server that return types with arguments of type Consumer

Modifier and Type	Method and Description
Collection<Consumer>	Queue.getConsumers()
Map<SimpleString,Consumer>	Queue.getGroups()

Methods in org.apache.activemq.artemis.core.server with parameters of type Consumer

Modifier and Type	Method and Description
void	Queue.addConsumer(Consumer consumer)
default void	Queue.errorProcessing(Consumer consumer, Throwable t, MessageReference messageReference)
void	Queue.removeConsumer(Consumer consumer)
void	ActiveMQServerLogger.removingBadConsumer(Throwable e, Consumer consumer, Object reference)
void	ActiveMQServerLogger_$logger.removingBadConsumer(Throwable e, Consumer consumer, Object reference)

Uses of Consumer in org.apache.activemq.artemis.core.server.cluster

Subinterfaces of Consumer in org.apache.activemq.artemis.core.server.cluster

Modifier and Type	Interface and Description
interface	Bridge A Core Bridge

Uses of Consumer in org.apache.activemq.artemis.core.server.cluster.impl

Classes in org.apache.activemq.artemis.core.server.cluster.impl that implement Consumer

Modifier and Type	Class and Description
class	BridgeImpl A Core BridgeImpl
class	ClusterConnectionBridge A bridge with extra functionality only available when the server is clustered.
class	Redistributor

Uses of Consumer in org.apache.activemq.artemis.core.server.impl

Classes in org.apache.activemq.artemis.core.server.impl with type parameters of type Consumer

Modifier and Type	Class and Description
protected static class	QueueImpl.ConsumerHolder<T extends Consumer>

Classes in org.apache.activemq.artemis.core.server.impl that implement Consumer

Modifier and Type	Class and Description
class	ServerConsumerImpl Concrete implementation of a ClientConsumer.

Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type Consumer

Modifier and Type	Method and Description
Set<Consumer>	QueueImpl.getConsumers()
Map<SimpleString,Consumer>	QueueImpl.getGroups()
static MessageGroups<Consumer>	QueueImpl.groupMap(int groupBuckets)

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type Consumer

Modifier and Type	Method and Description
void	QueueImpl.addConsumer(Consumer consumer)
void	QueueImpl.errorProcessing(Consumer consumer, Throwable t, MessageReference reference) This will print errors and decide what to do with the errored consumer from the protocol layer.
void	QueueImpl.removeConsumer(Consumer consumer)

Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type Consumer

Modifier and Type	Method and Description
protected void	QueueImpl.removeMessageReference(QueueImpl.ConsumerHolder<? extends Consumer> holder, MessageReference ref)