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) |
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 |
ChannelN.processAsync(Command command)
Protected API - Filters the inbound command stream, processing
Basic.Deliver, Basic.Return and Channel.Close specially.
|
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 © 2022 VMware, Inc. or its affiliates.. All rights reserved.