Uses of Class
com.rabbitmq.client.impl.AMQCommand
Package
Description
Implementations of interfaces specified in the client API, and their supporting classes.
-
Uses of AMQCommand in com.rabbitmq.client.impl
Modifier and TypeMethodDescriptionAMQChannel.exnWrappingRpc
(Method m) Placeholder until we address bug 15786 (implementing a proper exception hierarchy).Protected API - sends aMethod
to the broker and waits for the next in-bound Command from the broker: only for use from non-connection-MainLoop threads!AMQChannel.SimpleBlockingRpcContinuation.transformReply
(AMQCommand command) Modifier and TypeMethodDescriptionboolean
AMQChannel.BlockingRpcContinuation.canHandleReply
(AMQCommand command) boolean
AMQChannel.RpcContinuation.canHandleReply
(AMQCommand command) boolean
CompletableFutureRpcWrapper.canHandleReply
(AMQCommand command) boolean
RpcContinuationRpcWrapper.canHandleReply
(AMQCommand command) boolean
RpcWrapper.canHandleReply
(AMQCommand command) void
CompletableFutureRpcWrapper.complete
(AMQCommand command) void
RpcContinuationRpcWrapper.complete
(AMQCommand command) void
RpcWrapper.complete
(AMQCommand command) void
AMQChannel.BlockingRpcContinuation.handleCommand
(AMQCommand command) void
AMQChannel.RpcContinuation.handleCommand
(AMQCommand command) void
AMQChannel.handleCompleteInboundCommand
(AMQCommand command) Private API - handle a command which has been assembledvoid
AMQChannel.quiescingTransmit
(AMQCommand c) abstract T
AMQChannel.BlockingRpcContinuation.transformReply
(AMQCommand command) AMQChannel.SimpleBlockingRpcContinuation.transformReply
(AMQCommand command) void
AMQChannel.transmit
(AMQCommand c)