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

Packages that use ServerConsumer

Package	Description
org.apache.activemq.artemis.core.management.impl.view
org.apache.activemq.artemis.core.management.impl.view.predicate
org.apache.activemq.artemis.core.paging.cursor
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.federation.queue
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.server.plugin
org.apache.activemq.artemis.core.server.plugin.impl
org.apache.activemq.artemis.spi.core.protocol

Uses of ServerConsumer in org.apache.activemq.artemis.core.management.impl.view

Methods in org.apache.activemq.artemis.core.management.impl.view with parameters of type ServerConsumer

Modifier and Type	Method	Description
static String	ConsumerView.checkConsumerStatus(ServerConsumer consumer, ActiveMQServer server)
Object	ConsumerView.getField(ServerConsumer consumer, String fieldName)
JsonObjectBuilder	ConsumerView.toJson(ServerConsumer consumer)

Uses of ServerConsumer in org.apache.activemq.artemis.core.management.impl.view.predicate

Methods in org.apache.activemq.artemis.core.management.impl.view.predicate with parameters of type ServerConsumer

Modifier and Type	Method	Description
boolean	ConsumerFilterPredicate.test(ServerConsumer consumer)

Uses of ServerConsumer in org.apache.activemq.artemis.core.paging.cursor

Methods in org.apache.activemq.artemis.core.paging.cursor with parameters of type ServerConsumer

Modifier and Type	Method	Description
void	PagedReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer)
void	PagedReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering)
void	PagedReferenceImpl.acknowledge(Transaction tx, ServerConsumer consumer)

Uses of ServerConsumer in org.apache.activemq.artemis.core.protocol.core.impl

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ServerConsumer

Modifier and Type	Method	Description
void	CoreSessionCallback.browserFinished(ServerConsumer consumer)
void	CoreSessionCallback.disconnect(ServerConsumer consumerId, String errorMessage)
boolean	CoreSessionCallback.hasCredits(ServerConsumer consumer)
int	CoreSessionCallback.sendLargeMessage(MessageReference ref, ServerConsumer consumer, long bodySize, int deliveryCount)
int	CoreSessionCallback.sendLargeMessageContinuation(ServerConsumer consumer, byte[] body, boolean continues, boolean requiresResponse)
int	CoreSessionCallback.sendMessage(MessageReference ref, ServerConsumer consumer, int deliveryCount)
boolean	CoreSessionCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed)

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

Methods in org.apache.activemq.artemis.core.server that return ServerConsumer

Modifier and Type	Method	Description
ServerConsumer	ServerSession.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly)
ServerConsumer	ServerSession.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits)
ServerConsumer	ServerSession.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits)
ServerConsumer	ServerSession.locateConsumer(long consumerID)

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

Modifier and Type	Method	Description
Set<ServerConsumer>	ServerSession.getServerConsumers()

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

Modifier and Type	Method	Description
void	MessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer)
void	MessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering)
void	MessageReference.acknowledge(Transaction tx, ServerConsumer consumer)
void	Queue.acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer)
void	Queue.acknowledge(MessageReference ref, ServerConsumer consumer)
void	Queue.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer, boolean delivering)
void	ServerSession.addLingerConsumer(ServerConsumer consumer)
boolean	ActiveMQServer.callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference)
void	Queue.expire(MessageReference ref, ServerConsumer consumer, boolean delivering)
void	SlowConsumerDetectionListener.onSlowConsumer(ServerConsumer consumer)

Uses of ServerConsumer in org.apache.activemq.artemis.core.server.federation.queue

Methods in org.apache.activemq.artemis.core.server.federation.queue with parameters of type ServerConsumer

Modifier and Type	Method	Description
void	FederatedQueue.afterCreateConsumer(ServerConsumer consumer)	After a consumer has been created
void	FederatedQueue.beforeCloseConsumer(ServerConsumer consumer, boolean failed)	Before a consumer is closed
boolean	FederatedQueue.Matcher.test(ServerConsumer consumer)

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

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

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

Fields in org.apache.activemq.artemis.core.server.impl with type parameters of type ServerConsumer

Modifier and Type	Field	Description
protected final Map<Long,ServerConsumer>	ServerSessionImpl.consumers

Methods in org.apache.activemq.artemis.core.server.impl that return ServerConsumer

Modifier and Type	Method	Description
ServerConsumer	ServerSessionImpl.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly)
ServerConsumer	ServerSessionImpl.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage, Integer credits)
ServerConsumer	ServerSessionImpl.createConsumer(long consumerID, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, boolean supportLargeMessage, Integer credits)
ServerConsumer	ServerSessionImpl.locateConsumer(long consumerID)

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

Modifier and Type	Method	Description
Set<ServerConsumer>	ServerSessionImpl.getServerConsumers()

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

Modifier and Type	Method	Description
void	GroupFirstMessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer)
void	GroupFirstMessageReference.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering)
void	GroupFirstMessageReference.acknowledge(Transaction tx, ServerConsumer consumer)
void	LastValueQueue.acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer)
void	LastValueQueue.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer, boolean delivering)
void	MessageReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer)
void	MessageReferenceImpl.acknowledge(Transaction tx, AckReason reason, ServerConsumer consumer, boolean delivering)
void	MessageReferenceImpl.acknowledge(Transaction tx, ServerConsumer consumer)
void	QueueImpl.acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer)
void	QueueImpl.acknowledge(MessageReference ref, ServerConsumer consumer)
void	QueueImpl.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer, boolean delivering)	The parameter delivering can be sent as false in situation where the ack is coming outside of the context of delivering.
void	ServerSessionImpl.addLingerConsumer(ServerConsumer consumer)
boolean	ActiveMQServerImpl.callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference)
void	QueueImpl.expire(MessageReference ref, ServerConsumer consumer, boolean delivering)	The parameter delivering can be sent as false in situation where the ack is coming outside of the context of delivering.

Uses of ServerConsumer in org.apache.activemq.artemis.core.server.plugin

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

Modifier and Type	Method	Description
default void	ActiveMQServerConsumerPlugin.afterCloseConsumer(ServerConsumer consumer, boolean failed)	After a consumer is closed
default void	ActiveMQServerConsumerPlugin.afterCreateConsumer(ServerConsumer consumer)	After a consumer has been created
default void	ActiveMQServerMessagePlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)	After a message is delivered to a client consumer
default void	ActiveMQServerConsumerPlugin.beforeCloseConsumer(ServerConsumer consumer, boolean failed)	Before a consumer is closed
default void	ActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
default boolean	ActiveMQServerMessagePlugin.canAccept(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
default boolean	ActiveMQServerFederationPlugin.federatedQueueConditionalCreateConsumer(ServerConsumer consumer)	Conditionally create a federated queue consumer for a federated queue.
default void	ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason, ServerConsumer consumer)	Deprecated.
default void	ActiveMQServerMessagePlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)	A message has been acknowledged
default void	ActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)	A message has been expired
default void	ActiveMQServerMessagePlugin.messageMoved(Transaction tx, MessageReference ref, AckReason reason, SimpleString destAddress, Long destQueueID, ServerConsumer consumer, Message newMessage, RoutingStatus result)	A message has been moved

Uses of ServerConsumer in org.apache.activemq.artemis.core.server.plugin.impl

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

Modifier and Type	Method	Description
void	LoggingActiveMQServerPlugin.afterCloseConsumer(ServerConsumer consumer, boolean failed)	After a consumer is closed
void	LoggingActiveMQServerPlugin.afterCreateConsumer(ServerConsumer consumer)	After a consumer has been created
void	LoggingActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)	After a message is delivered to a client consumer
void	NotificationActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPluginLogger_impl.afterDeliverDetails(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID, MessageReference reference, ServerConsumer consumer)
void	LoggingActiveMQServerPluginLogger.afterDeliverDetails(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID, MessageReference reference, ServerConsumer consumer)
void	LoggingActiveMQServerPlugin.beforeCloseConsumer(ServerConsumer consumer, boolean failed)	Before a consumer is closed
void	LoggingActiveMQServerPluginLogger_impl.beforeCloseConsumer(ServerConsumer consumer, String sessionID, boolean failed)
void	LoggingActiveMQServerPluginLogger.beforeCloseConsumer(ServerConsumer consumer, String sessionID, boolean failed)
void	LoggingActiveMQServerPlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference)	Before a message is delivered to a client consumer
void	LoggingActiveMQServerPluginLogger_impl.beforeDeliver(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPluginLogger.beforeDeliver(ServerConsumer consumer, MessageReference reference)
boolean	BrokerMessageAuthorizationPlugin.canAccept(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPlugin.messageAcknowledged(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)	A message has been acknowledged
void	LoggingActiveMQServerPlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)
void	NotificationActiveMQServerPlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)

Uses of ServerConsumer in org.apache.activemq.artemis.spi.core.protocol

Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type ServerConsumer

Modifier and Type	Method	Description
void	SessionCallback.browserFinished(ServerConsumer consumer)	Some protocols (Openwire) needs a special message with the browser is finished.
void	SessionCallback.disconnect(ServerConsumer consumerId, String errorMessage)
boolean	SessionCallback.hasCredits(ServerConsumer consumerID)	This one gives a chance for Proton to have its own flow control.
default boolean	SessionCallback.hasCredits(ServerConsumer consumerID, MessageReference ref)	This one includes the MessageReference for protocols like MQTT 5 (which only enforces flow control on durable messages (i.e.
int	SessionCallback.sendLargeMessage(MessageReference ref, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	SessionCallback.sendLargeMessageContinuation(ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	SessionCallback.sendMessage(MessageReference ref, ServerConsumer consumerID, int deliveryCount)
boolean	SessionCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed)	Use this to updates specifics on the message after a redelivery happened.