Uses of Interface
com.rabbitmq.client.Consumer
Packages that use Consumer
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementations of interfaces specified in the client API, and their supporting classes.
Implementation of connection and topology recovery.
-
Uses of Consumer in com.rabbitmq.client
Subinterfaces of Consumer in com.rabbitmq.clientClasses in com.rabbitmq.client that implement ConsumerModifier and TypeClassDescriptionclass
Convenience class providing a default implementation ofConsumer
.private static class
Methods in com.rabbitmq.client that return ConsumerModifier and TypeMethodDescriptionRpcClient.getConsumer()
Retrieve the consumer.Channel.getDefaultConsumer()
Get the current default consumer.Methods in com.rabbitmq.client with parameters of type ConsumerModifier and TypeMethodDescriptionChannel.basicConsume
(String queue, boolean autoAck, Consumer callback) Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.Channel.basicConsume
(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String, Object> arguments, Consumer callback) Start a consumer.Channel.basicConsume
(String queue, boolean autoAck, String consumerTag, Consumer callback) Start a non-nolocal, non-exclusive consumer.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.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
Fields in com.rabbitmq.client.impl declared as ConsumerModifier and TypeFieldDescriptionprivate Consumer
ChannelN.defaultConsumer
The current default consumer, or null if there is none.Fields in com.rabbitmq.client.impl with type parameters of type ConsumerMethods in com.rabbitmq.client.impl that return ConsumerModifier and TypeMethodDescriptionprivate 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) ChannelN.getDefaultConsumer()
Returns the current default consumer.Methods in com.rabbitmq.client.impl with parameters of type ConsumerModifier and TypeMethodDescriptionChannelN.basicConsume
(String queue, boolean autoAck, Consumer callback) Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.ChannelN.basicConsume
(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String, Object> arguments, Consumer callback) Public API - Start a consumer.ChannelN.basicConsume
(String queue, boolean autoAck, String consumerTag, Consumer callback) Public API - Start a non-nolocal, non-exclusive consumer.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.ChannelN.basicConsume
(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, String consumerTag) void
ConsumerDispatcher.handleCancelOk
(Consumer delegate, String consumerTag) void
ConsumerDispatcher.handleConsumeOk
(Consumer delegate, String 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
ConsumerDispatcher.handleDelivery
(Consumer delegate, String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) void
ConsumerDispatcher.handleRecoverOk
(Consumer delegate, String consumerTag) private void
ConsumerDispatcher.notifyConsumerOfShutdown
(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 ConsumerModifier and TypeMethodDescriptionConsumerDispatcher.handleShutdownSignal
(Map<String, Consumer> consumers, ShutdownSignalException signal) private void
ConsumerDispatcher.notifyConsumersOfShutdown
(Map<String, Consumer> consumers, ShutdownSignalException signal) -
Uses of Consumer in com.rabbitmq.client.impl.recovery
Fields in com.rabbitmq.client.impl.recovery declared as ConsumerMethods in com.rabbitmq.client.impl.recovery that return ConsumerModifier and TypeMethodDescriptionprivate 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) AutorecoveringChannel.getDefaultConsumer()
Methods in com.rabbitmq.client.impl.recovery with parameters of type ConsumerModifier and TypeMethodDescriptionAutorecoveringChannel.basicConsume
(String queue, boolean autoAck, Consumer callback) AutorecoveringChannel.basicConsume
(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String, Object> arguments, Consumer callback) AutorecoveringChannel.basicConsume
(String queue, boolean autoAck, String consumerTag, Consumer callback) AutorecoveringChannel.basicConsume
(String queue, boolean autoAck, Map<String, Object> arguments, Consumer callback) AutorecoveringChannel.basicConsume
(String queue, Consumer callback) private void
AutorecoveringChannel.recordConsumer
(String result, String queue, boolean autoAck, boolean exclusive, Map<String, 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 ConsumerModifier and TypeMethodDescriptionNoOpObservationCollector.basicConsume
(String queue, String consumerTag, Consumer consumer) ObservationCollector.basicConsume
(String queue, String consumerTag, Consumer consumer) Decorate consumer registration.Methods in com.rabbitmq.client.observation with parameters of type ConsumerModifier and TypeMethodDescriptionNoOpObservationCollector.basicConsume
(String queue, String consumerTag, Consumer consumer) ObservationCollector.basicConsume
(String queue, String consumerTag, Consumer consumer) Decorate consumer registration.