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

Packages that use ServerConsumer

Package	Description
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.spi.core.protocol

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 and Description
void	CoreSessionCallback.browserFinished(ServerConsumer consumer)
void	CoreSessionCallback.disconnect(ServerConsumer consumerId, String queueName)
boolean	CoreSessionCallback.hasCredits(ServerConsumer consumer)
int	CoreSessionCallback.sendLargeMessage(MessageReference ref, ServerMessage message, ServerConsumer consumer, long bodySize, int deliveryCount)
int	CoreSessionCallback.sendLargeMessageContinuation(ServerConsumer consumer, byte[] body, boolean continues, boolean requiresResponse)
int	CoreSessionCallback.sendMessage(MessageReference ref, ServerMessage message, 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 and Description
ServerConsumer	ServerSession.createConsumer(long consumerID, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean browseOnly)
ServerConsumer	ServerSession.createConsumer(long consumerID, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, 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 and Description
Set<ServerConsumer>	ServerSession.getServerConsumers()

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

Modifier and Type	Method and Description
void	SlowConsumerDetectionListener.onSlowConsumer(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 and 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 and Description
protected Map<Long,ServerConsumer>	ServerSessionImpl.consumers

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

Modifier and Type	Method and Description
ServerConsumer	ServerSessionImpl.createConsumer(long consumerID, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean browseOnly)
ServerConsumer	ServerSessionImpl.createConsumer(long consumerID, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, 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 and Description
Set<ServerConsumer>	ServerSessionImpl.getServerConsumers()

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 and Description
void	SessionCallback.browserFinished(ServerConsumer consumer) Some protocols (Openwire) needs a special message with the browser is finished.
void	SessionCallback.disconnect(ServerConsumer consumerId, String queueName)
boolean	SessionCallback.hasCredits(ServerConsumer consumerID) This one gives a chance for Proton to have its own flow control.
int	SessionCallback.sendLargeMessage(MessageReference reference, ServerMessage message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	SessionCallback.sendLargeMessageContinuation(ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	SessionCallback.sendMessage(MessageReference ref, ServerMessage message, 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.