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 | Method and Description |
---|---|
String |
Channel.basicConsume(String queue,
boolean autoAck,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Start a non-nolocal, non-exclusive consumer, with
a server-generated consumerTag.
|
String |
Channel.basicConsume(String queue,
boolean autoAck,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
Start a non-nolocal, non-exclusive consumer, with
a server-generated consumerTag.
|
String |
Channel.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Start a non-nolocal, non-exclusive consumer, with
a server-generated consumerTag and specified arguments.
|
String |
Channel.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
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,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Start a consumer.
|
String |
Channel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
boolean noLocal,
boolean exclusive,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
Start a consumer.
|
String |
Channel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Start a non-nolocal, non-exclusive consumer.
|
String |
Channel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
Start a non-nolocal, non-exclusive consumer.
|
String |
Channel.basicConsume(String queue,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Start a non-nolocal, non-exclusive consumer, with
explicit acknowledgement and a server-generated consumerTag.
|
String |
Channel.basicConsume(String queue,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
Start a non-nolocal, non-exclusive consumer, with
explicit acknowledgement and a server-generated consumerTag.
|
Modifier and Type | Method and Description |
---|---|
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Public API - Start a non-nolocal, non-exclusive consumer, with
a server-generated consumerTag.
|
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Public API - Start a non-nolocal, non-exclusive consumer, with
a server-generated consumerTag and specified arguments.
|
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
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,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Public API - Start a consumer.
|
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
String consumerTag,
boolean noLocal,
boolean exclusive,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
String consumerTag,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Public API - Start a non-nolocal, non-exclusive consumer.
|
String |
ChannelN.basicConsume(String queue,
boolean autoAck,
String consumerTag,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
Public API - Start a non-nolocal, non-exclusive consumer.
|
String |
ChannelN.basicConsume(String queue,
DeliverCallback deliverCallback,
CancelCallback cancelCallback)
Public API - Start a non-nolocal, non-exclusive consumer, with
explicit acknowledgement and a server-generated consumerTag.
|
String |
ChannelN.basicConsume(String queue,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback)
Public API - Start a non-nolocal, non-exclusive consumer, with
explicit acknowledgement and a server-generated consumerTag.
|
Modifier and Type | Method and Description |
---|---|
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
DeliverCallback deliverCallback,
CancelCallback cancelCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
boolean noLocal,
boolean exclusive,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
boolean noLocal,
boolean exclusive,
Map<String,Object> arguments,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
DeliverCallback deliverCallback,
CancelCallback cancelCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
boolean autoAck,
String consumerTag,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
DeliverCallback deliverCallback,
CancelCallback cancelCallback) |
String |
AutorecoveringChannel.basicConsume(String queue,
DeliverCallback deliverCallback,
CancelCallback cancelCallback,
ConsumerShutdownSignalCallback shutdownSignalCallback) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.