Uses of Interface
com.rabbitmq.client.Consumer
-
Packages that use Consumer Package Description com.rabbitmq.client The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.com.rabbitmq.client.impl Implementations of interfaces specified in the client API, and their supporting classes.com.rabbitmq.client.impl.recovery Implementation of connection and topology recovery. -
-
Uses of Consumer in com.rabbitmq.client
Classes in com.rabbitmq.client that implement Consumer Modifier and Type Class Description classDefaultConsumerConvenience class providing a default implementation ofConsumer.classQueueingConsumerDeprecated.Methods in com.rabbitmq.client that return Consumer Modifier and Type Method Description ConsumerRpcClient. getConsumer()Retrieve the consumer.ConsumerChannel. getDefaultConsumer()Get the current default consumer.Methods in com.rabbitmq.client with parameters of type Consumer Modifier and Type Method Description StringChannel. basicConsume(String queue, boolean autoAck, Consumer callback)Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.StringChannel. basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)Start a consumer.StringChannel. basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)Start a non-nolocal, non-exclusive consumer.StringChannel. basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, Consumer callback)Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.StringChannel. basicConsume(String queue, Consumer callback)Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.voidExceptionHandler. handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)Perform any required exception processing for the situation when the driver thread for the connection has called a method on a Consumer, and that method has thrown an exception.voidChannel. setDefaultConsumer(Consumer consumer)Set the current default consumer. -
Uses of Consumer in com.rabbitmq.client.impl
Methods in com.rabbitmq.client.impl that return Consumer Modifier and Type Method Description ConsumerChannelN. getDefaultConsumer()Returns the current default consumer.Methods in com.rabbitmq.client.impl with parameters of type Consumer Modifier and Type Method Description StringChannelN. basicConsume(String queue, boolean autoAck, Consumer callback)Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.StringChannelN. basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)Public API - Start a consumer.StringChannelN. basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)Public API - Start a non-nolocal, non-exclusive consumer.StringChannelN. basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, Consumer callback)Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.StringChannelN. basicConsume(String queue, Consumer callback)Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.voidForgivingExceptionHandler. handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)voidStrictExceptionHandler. handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)voidChannelN. setDefaultConsumer(Consumer consumer)Sets the current default consumer. -
Uses of Consumer in com.rabbitmq.client.impl.recovery
Methods in com.rabbitmq.client.impl.recovery that return Consumer Modifier and Type Method Description ConsumerAutorecoveringChannel. getDefaultConsumer()Methods in com.rabbitmq.client.impl.recovery with parameters of type Consumer Modifier and Type Method Description StringAutorecoveringChannel. basicConsume(String queue, boolean autoAck, Consumer callback)StringAutorecoveringChannel. basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)StringAutorecoveringChannel. basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)StringAutorecoveringChannel. basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, Consumer callback)StringAutorecoveringChannel. basicConsume(String queue, Consumer callback)RecordedConsumerRecordedConsumer. consumer(Consumer value)voidAutorecoveringChannel. setDefaultConsumer(Consumer consumer)
-