Uses of Interface
org.apache.activemq.artemis.api.core.client.ClientConsumer
-
-
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 ClientConsumerClientSession. createConsumer(String queueName)Creates a ClientConsumer to consume messages from the queue with the given name.ClientConsumerClientSession. createConsumer(String queueName, boolean browseOnly)Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientConsumerClientSession. createConsumer(String queueName, String filter)Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientConsumerClientSession. createConsumer(SimpleString queueName)Creates a ClientConsumer to consume message from the queue with the given name.ClientConsumerClientSession. createConsumer(SimpleString queueName, boolean browseOnly)Creates a ClientConsumer to consume or browse messages from the queue with the given name.ClientConsumerClientSession. createConsumer(SimpleString queueName, SimpleString filter)Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientConsumerClientSession. 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.ClientConsumerClientConsumer. 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 interfaceClientConsumerInternalClasses in org.apache.activemq.artemis.core.client.impl that implement ClientConsumer Modifier and Type Class Description classClientConsumerImplMethods in org.apache.activemq.artemis.core.client.impl that return ClientConsumer Modifier and Type Method Description ClientConsumerClientSessionImpl. createConsumer(String queueName)ClientConsumerClientSessionImpl. createConsumer(String queueName, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(String queueName, String filterString)ClientConsumerClientSessionImpl. createConsumer(String queueName, String filterString, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(String queueName, String filterString, int windowSize, int maxRate, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, int windowSize, int maxRate, boolean browseOnly)ClientConsumerClientSessionImpl. createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, boolean browseOnly)Note, we DO NOT currently support direct consumers (i.e.Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ClientConsumer Modifier and Type Method Description voidClientSessionImpl. acknowledge(ClientConsumer consumer, Message message)Acknowledges all messages received by the consumer so far.voidClientSessionInternal. acknowledge(ClientConsumer consumer, Message message)voidClientSessionImpl. expire(ClientConsumer consumer, Message message)voidClientSessionInternal. expire(ClientConsumer consumer, Message message)voidClientSessionImpl. individualAcknowledge(ClientConsumer consumer, Message message)voidClientSessionInternal. 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 voidActiveMQSessionContext. closeConsumer(ClientConsumer consumer)voidActiveMQSessionContext. expireMessage(ClientConsumer consumer, Message message)voidActiveMQSessionContext. forceDelivery(ClientConsumer consumer, long sequence)voidActiveMQSessionContext. sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)voidActiveMQSessionContext. 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 Constructor Description ActiveMQMessageConsumer(ConnectionFactoryOptions options, ActiveMQConnection connection, ActiveMQSession session, ClientConsumer consumer, boolean noLocal, ActiveMQDestination destination, String selector, SimpleString autoDeleteQueueName)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 voidSessionContext. closeConsumer(ClientConsumer consumer)abstract voidSessionContext. expireMessage(ClientConsumer consumer, Message message)abstract voidSessionContext. forceDelivery(ClientConsumer consumer, long sequence)abstract voidSessionContext. sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)abstract voidSessionContext. sendConsumerCredits(ClientConsumer consumer, int credits)
-