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.
com.rabbitmq.client.observation

Uses of Consumer in com.rabbitmq.client

Subinterfaces of Consumer in com.rabbitmq.client

Modifier and Type	Interface	Description
static interface	RpcServer.RpcConsumer

Classes in com.rabbitmq.client that implement Consumer

Modifier and Type	Class	Description
class	DefaultConsumer	Convenience class providing a default implementation of Consumer.

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)

Uses of Consumer in com.rabbitmq.client.observation

Methods in com.rabbitmq.client.observation that return Consumer

Modifier and Type	Method	Description
Consumer	ObservationCollector.basicConsume(String queue, String consumerTag, Consumer consumer)	Decorate consumer registration.

Methods in com.rabbitmq.client.observation with parameters of type Consumer

Modifier and Type	Method	Description
Consumer	ObservationCollector.basicConsume(String queue, String consumerTag, Consumer consumer)	Decorate consumer registration.