Uses of Interface
org.apache.activemq.artemis.api.core.client.ClientConsumer

Packages that use ClientConsumer

Package	Description
org.apache.activemq.artemis.api.core.client
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.jms.client
org.apache.activemq.artemis.spi.core.remoting

Uses of ClientConsumer in org.apache.activemq.artemis.api.core.client

Methods in org.apache.activemq.artemis.api.core.client that return ClientConsumer

Modifier and Type	Method	Description
ClientConsumer	ClientSession.createConsumer(String queueName)	Creates a ClientConsumer to consume messages from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, String filter)	Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, String filter, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(String queueName, String filter, int windowSize, int maxRate, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName)	Creates a ClientConsumer to consume message from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter)	Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int priority, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int windowSize, int maxRate, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientSession.createConsumer(SimpleString queueName, SimpleString filter, int priority, int windowSize, int maxRate, boolean browseOnly)	Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
ClientConsumer	ClientConsumer.setMessageHandler(MessageHandler handler)	Sets the MessageHandler for this consumer to consume messages asynchronously.

Uses of ClientConsumer in org.apache.activemq.artemis.core.client.impl

Subinterfaces of ClientConsumer in org.apache.activemq.artemis.core.client.impl

Modifier and Type	Interface	Description
interface	ClientConsumerInternal

Classes in org.apache.activemq.artemis.core.client.impl that implement ClientConsumer

Modifier and Type	Class	Description
final class	ClientConsumerImpl

Methods in org.apache.activemq.artemis.core.client.impl that return ClientConsumer

Modifier and Type	Method	Description
ClientConsumer	ClientSessionImpl.createConsumer(String queueName)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, String filterString)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, String filterString, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(String queueName, String filterString, int windowSize, int maxRate, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly)
ClientConsumer	ClientSessionImpl.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, boolean browseOnly)	Note, we DO NOT currently support direct consumers (i.e. consumers where delivery occurs on the remoting thread).
ClientConsumer	ClientConsumerImpl.setManualFlowMessageHandler(MessageHandler theHandler)
ClientConsumer	ClientConsumerInternal.setManualFlowMessageHandler(MessageHandler theHandler)

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ClientConsumer

Modifier and Type	Method	Description
void	ClientSessionImpl.acknowledge(ClientConsumer consumer, Message message)
void	ClientSessionInternal.acknowledge(ClientConsumer consumer, Message message)
void	ClientSessionImpl.expire(ClientConsumer consumer, Message message)
void	ClientSessionInternal.expire(ClientConsumer consumer, Message message)
void	ClientSessionImpl.individualAcknowledge(ClientConsumer consumer, Message message)
void	ClientSessionInternal.individualAcknowledge(ClientConsumer consumer, Message message)

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

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

Modifier and Type	Method	Description
void	ActiveMQSessionContext.closeConsumer(ClientConsumer consumer)
void	ActiveMQSessionContext.expireMessage(ClientConsumer consumer, Message message)
void	ActiveMQSessionContext.forceDelivery(ClientConsumer consumer, long sequence)
void	ActiveMQSessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)
void	ActiveMQSessionContext.sendConsumerCredits(ClientConsumer consumer, int credits)

Uses of ClientConsumer in org.apache.activemq.artemis.jms.client

Constructors in org.apache.activemq.artemis.jms.client with parameters of type ClientConsumer

Modifier	Constructor	Description
protected	ActiveMQMessageConsumer(ConnectionFactoryOptions options, ActiveMQConnection connection, ActiveMQSession session, ClientConsumer consumer, boolean noLocal, ActiveMQDestination destination, String selector, SimpleString autoDeleteQueueName)
protected	JMSMessageListenerWrapper(ConnectionFactoryOptions options, ActiveMQConnection connection, ActiveMQSession session, ClientConsumer consumer, MessageListener listener, int ackMode)

Uses of ClientConsumer in org.apache.activemq.artemis.spi.core.remoting

Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ClientConsumer

Modifier and Type	Method	Description
abstract void	SessionContext.closeConsumer(ClientConsumer consumer)
abstract void	SessionContext.expireMessage(ClientConsumer consumer, Message message)
abstract void	SessionContext.forceDelivery(ClientConsumer consumer, long sequence)
abstract void	SessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)
abstract void	SessionContext.sendConsumerCredits(ClientConsumer consumer, int credits)