Uses of Interface
com.rabbitmq.client.Command
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 Command in com.rabbitmq.client
Modifier and TypeMethodDescriptionSynchronously send a method over this channel.Modifier and TypeMethodDescriptionChannel.asyncCompletableRpc
(Method method) Asynchronously send a method over this channel. -
Uses of Command in com.rabbitmq.client.impl
Modifier and TypeClassDescriptionclass
AMQP 0-9-1-specific implementation ofCommand
which accumulates method, header and body from a series of frames, unless these are supplied at construction time.Modifier and TypeMethodDescriptionChannelN.asyncCompletableRpc
(Method method) AMQChannel.exnWrappingAsyncRpc
(Method m) Modifier and TypeMethodDescriptionvoid
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
protected boolean
void
Modifier and TypeMethodDescriptionvoid
AMQChannel.asyncRpc
(Method m, CompletableFuture<Command> future) void
AMQChannel.enqueueAsyncRpc
(Method method, CompletableFuture<Command> future) void
AMQChannel.quiescingAsyncRpc
(Method m, CompletableFuture<Command> future) ModifierConstructorDescriptionCompletableFutureRpcWrapper
(Method method, CompletableFuture<Command> completableFuture) -
Uses of Command in com.rabbitmq.client.impl.recovery
Modifier and TypeMethodDescriptionprotected void
RecoveryAwareChannelN.processDelivery
(Command command, AMQImpl.Basic.Deliver method)