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.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
RpcServer.RpcConsumer |
Modifier and Type | Class and Description |
---|---|
class |
DefaultConsumer
Convenience class providing a default implementation of
Consumer . |
Modifier and Type | Method and Description |
---|---|
Consumer |
RpcClient.getConsumer()
Retrieve the consumer.
|
Consumer |
Channel.getDefaultConsumer()
Get the current default consumer.
|
Modifier and Type | Method and 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,
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,
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,
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.
|
Modifier and Type | Method and Description |
---|---|
Consumer |
ChannelN.getDefaultConsumer()
Returns the current default consumer.
|
Modifier and Type | Method and 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,
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,
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,
Consumer callback)
Public API - Start a non-nolocal, non-exclusive consumer, with
explicit acknowledgement and a server-generated consumerTag.
|
void |
StrictExceptionHandler.handleConsumerException(Channel channel,
Throwable exception,
Consumer consumer,
String consumerTag,
String methodName) |
void |
ForgivingExceptionHandler.handleConsumerException(Channel channel,
Throwable exception,
Consumer consumer,
String consumerTag,
String methodName) |
void |
ChannelN.setDefaultConsumer(Consumer consumer)
Sets the current default consumer.
|
Modifier and Type | Method and Description |
---|---|
Consumer |
AutorecoveringChannel.getDefaultConsumer() |
Modifier and Type | Method and Description |
---|---|
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
Consumer callback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
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,
Consumer callback) |
RecordedConsumer |
RecordedConsumer.consumer(Consumer value) |
void |
AutorecoveringChannel.setDefaultConsumer(Consumer consumer) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.