Uses of Interface
org.apache.activemq.artemis.api.core.client.ClientConsumer
Packages that use ClientConsumer
Package
Description
-
Uses of ClientConsumer in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return ClientConsumerModifier and TypeMethodDescriptionClientSession.createConsumer
(String queueName) Creates a ClientConsumer to consume messages from the queue with the given name.ClientSession.createConsumer
(String queueName, boolean browseOnly) Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientSession.createConsumer
(String queueName, String filter) Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.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.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.ClientSession.createConsumer
(SimpleString queueName) Creates a ClientConsumer to consume message from the queue with the given name.ClientSession.createConsumer
(SimpleString queueName, boolean browseOnly) Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientSession.createConsumer
(SimpleString queueName, SimpleString filter) Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.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.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.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.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.setMessageHandler
(MessageHandler handler) Sets the MessageHandler for this consumer to consume messages asynchronously. -
Uses of ClientConsumer in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ClientConsumerModifier and TypeMethodDescriptionabstract 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)