| 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 |
|---|---|
Command |
Channel.rpc(Method method)
Synchronously send a method over this channel.
|
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Command> |
Channel.asyncCompletableRpc(Method method)
Asynchronously send a method over this channel.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TrafficListener.read(Command inboundCommand)
Notified for each inbound
Command. |
void |
TrafficListener.write(Command outboundCommand)
Notified for each outbound
Command. |
| Modifier and Type | Class and Description |
|---|---|
class |
AMQCommand
AMQP 0-9-1-specific implementation of
Command which accumulates
method, header and body from a series of frames, unless these are
supplied at construction time. |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Command> |
ChannelN.asyncCompletableRpc(Method method) |
CompletableFuture<Command> |
AMQChannel.exnWrappingAsyncRpc(Method m) |
| Modifier and Type | Method and Description |
|---|---|
void |
AMQConnection.handleConnectionClose(Command closeCommand) |
boolean |
ChannelN.processAsync(Command command)
Protected API - Filters the inbound command stream, processing
Basic.Deliver, Basic.Return and Channel.Close specially.
|
abstract boolean |
AMQChannel.processAsync(Command command)
Protected API - called by nextCommand to check possibly handle an incoming Command before it is returned to the caller of nextCommand.
|
boolean |
AMQConnection.processControlCommand(Command c)
Handles incoming control commands on channel zero.
|
protected void |
ChannelN.processDelivery(Command command,
AMQImpl.Basic.Deliver method) |
void |
LogTrafficListener.read(Command inboundCommand) |
protected boolean |
LogTrafficListener.shouldLog(Command command) |
void |
LogTrafficListener.write(Command outboundCommand) |
| Modifier and Type | Method and Description |
|---|---|
void |
AMQChannel.asyncRpc(Method m,
CompletableFuture<Command> future) |
void |
AMQChannel.enqueueAsyncRpc(Method method,
CompletableFuture<Command> future) |
void |
AMQChannel.quiescingAsyncRpc(Method m,
CompletableFuture<Command> future) |
| Constructor and Description |
|---|
CompletableFutureRpcWrapper(Method method,
CompletableFuture<Command> completableFuture) |
| Modifier and Type | Method and Description |
|---|---|
Command |
AutorecoveringChannel.rpc(Method method) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Command> |
AutorecoveringChannel.asyncCompletableRpc(Method method) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
RecoveryAwareChannelN.processDelivery(Command command,
AMQImpl.Basic.Deliver method) |
Copyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.