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 class
DefaultConsumer
Convenience class providing a default implementation ofConsumer
.class
QueueingConsumer
Deprecated.Methods in com.rabbitmq.client that return Consumer Modifier and Type Method Description Consumer
RpcClient. getConsumer()
Retrieve the consumer.Consumer
Channel. getDefaultConsumer()
Get the current default consumer.Methods in com.rabbitmq.client with parameters of type Consumer Modifier and Type Method Description String
Channel. basicConsume(String queue, boolean autoAck, Consumer callback)
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.String
Channel. basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)
Start a consumer.String
Channel. basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)
Start a non-nolocal, non-exclusive consumer.String
Channel. 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.String
Channel. basicConsume(String queue, Consumer callback)
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.void
ExceptionHandler. 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.void
Channel. 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 Consumer
ChannelN. getDefaultConsumer()
Returns the current default consumer.Methods in com.rabbitmq.client.impl with parameters of type Consumer Modifier and Type Method Description String
ChannelN. basicConsume(String queue, boolean autoAck, Consumer callback)
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.String
ChannelN. basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)
Public API - Start a consumer.String
ChannelN. basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)
Public API - Start a non-nolocal, non-exclusive consumer.String
ChannelN. 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.String
ChannelN. basicConsume(String queue, Consumer callback)
Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.void
ForgivingExceptionHandler. handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)
void
StrictExceptionHandler. handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName)
void
ChannelN. 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 Consumer
AutorecoveringChannel. getDefaultConsumer()
Methods in com.rabbitmq.client.impl.recovery with parameters of type Consumer Modifier and Type Method Description String
AutorecoveringChannel. basicConsume(String queue, boolean autoAck, Consumer callback)
String
AutorecoveringChannel. basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)
String
AutorecoveringChannel. basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)
String
AutorecoveringChannel. basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, Consumer callback)
String
AutorecoveringChannel. basicConsume(String queue, Consumer callback)
RecordedConsumer
RecordedConsumer. consumer(Consumer value)
void
AutorecoveringChannel. setDefaultConsumer(Consumer consumer)
-