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.
private static class	RpcServer.DefaultRpcConsumer

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
java.lang.String	Channel.basicConsume(java.lang.String queue, boolean autoAck, Consumer callback)	Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
java.lang.String	Channel.basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)	Start a consumer.
java.lang.String	Channel.basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, Consumer callback)	Start a non-nolocal, non-exclusive consumer.
java.lang.String	Channel.basicConsume(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)	Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
java.lang.String	Channel.basicConsume(java.lang.String queue, Consumer callback)	Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
void	ExceptionHandler.handleConsumerException(Channel channel, java.lang.Throwable exception, Consumer consumer, java.lang.String consumerTag, java.lang.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

Fields in com.rabbitmq.client.impl declared as Consumer

Modifier and Type	Field	Description
private Consumer	ChannelN.defaultConsumer	The current default consumer, or null if there is none.

Fields in com.rabbitmq.client.impl with type parameters of type Consumer

Modifier and Type	Field	Description
private java.util.Map<java.lang.String,Consumer>	ChannelN._consumers	Map from consumer tag to Consumer instance.

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

Modifier and Type	Method	Description
private Consumer	ChannelN.consumerFromDeliverCancelCallbacks(DeliverCallback deliverCallback, CancelCallback cancelCallback)
private Consumer	ChannelN.consumerFromDeliverCancelShutdownCallbacks(DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
private Consumer	ChannelN.consumerFromDeliverShutdownCallbacks(DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
Consumer	ChannelN.getDefaultConsumer()	Returns the current default consumer.

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

Modifier and Type	Method	Description
java.lang.String	ChannelN.basicConsume(java.lang.String queue, boolean autoAck, Consumer callback)	Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
java.lang.String	ChannelN.basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)	Public API - Start a consumer.
java.lang.String	ChannelN.basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, Consumer callback)	Public API - Start a non-nolocal, non-exclusive consumer.
java.lang.String	ChannelN.basicConsume(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)	Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
java.lang.String	ChannelN.basicConsume(java.lang.String queue, Consumer callback)	Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
void	ConsumerDispatcher.handleCancel(Consumer delegate, java.lang.String consumerTag)
void	ConsumerDispatcher.handleCancelOk(Consumer delegate, java.lang.String consumerTag)
void	ConsumerDispatcher.handleConsumeOk(Consumer delegate, java.lang.String consumerTag)
void	ForgivingExceptionHandler.handleConsumerException(Channel channel, java.lang.Throwable exception, Consumer consumer, java.lang.String consumerTag, java.lang.String methodName)
void	StrictExceptionHandler.handleConsumerException(Channel channel, java.lang.Throwable exception, Consumer consumer, java.lang.String consumerTag, java.lang.String methodName)
void	ConsumerDispatcher.handleDelivery(Consumer delegate, java.lang.String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
void	ConsumerDispatcher.handleRecoverOk(Consumer delegate, java.lang.String consumerTag)
private void	ConsumerDispatcher.notifyConsumerOfShutdown(java.lang.String consumerTag, Consumer consumer, ShutdownSignalException signal)
void	ChannelN.setDefaultConsumer(Consumer consumer)	Sets the current default consumer.

Method parameters in com.rabbitmq.client.impl with type arguments of type Consumer

Modifier and Type	Method	Description
java.util.concurrent.CountDownLatch	ConsumerDispatcher.handleShutdownSignal(java.util.Map<java.lang.String,Consumer> consumers, ShutdownSignalException signal)
private void	ConsumerDispatcher.notifyConsumersOfShutdown(java.util.Map<java.lang.String,Consumer> consumers, ShutdownSignalException signal)

Uses of Consumer in com.rabbitmq.client.impl.recovery

Fields in com.rabbitmq.client.impl.recovery declared as Consumer

Modifier and Type	Field	Description
private Consumer	RecordedConsumer.consumer

Methods in com.rabbitmq.client.impl.recovery that return Consumer

Modifier and Type	Method	Description
private Consumer	AutorecoveringChannel.consumerFromDeliverCancelCallbacks(DeliverCallback deliverCallback, CancelCallback cancelCallback)
private Consumer	AutorecoveringChannel.consumerFromDeliverCancelShutdownCallbacks(DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
private Consumer	AutorecoveringChannel.consumerFromDeliverShutdownCallbacks(DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
Consumer	AutorecoveringChannel.getDefaultConsumer()

Methods in com.rabbitmq.client.impl.recovery with parameters of type Consumer

Modifier and Type	Method	Description
java.lang.String	AutorecoveringChannel.basicConsume(java.lang.String queue, boolean autoAck, Consumer callback)
java.lang.String	AutorecoveringChannel.basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)
java.lang.String	AutorecoveringChannel.basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, Consumer callback)
java.lang.String	AutorecoveringChannel.basicConsume(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)
java.lang.String	AutorecoveringChannel.basicConsume(java.lang.String queue, Consumer callback)
RecordedConsumer	RecordedConsumer.consumer(Consumer value)
private void	AutorecoveringChannel.recordConsumer(java.lang.String result, java.lang.String queue, boolean autoAck, boolean exclusive, java.util.Map<java.lang.String,java.lang.Object> arguments, Consumer callback)
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	NoOpObservationCollector.basicConsume(java.lang.String queue, java.lang.String consumerTag, Consumer consumer)
Consumer	ObservationCollector.basicConsume(java.lang.String queue, java.lang.String consumerTag, Consumer consumer)	Decorate consumer registration.

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

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