Package | Description |
---|---|
com.rabbitmq.client.impl |
Implementations of interfaces specified in the client API, and their supporting classes.
|
Modifier and Type | Method and Description |
---|---|
AMQCommand |
AMQChannel.exnWrappingRpc(Method m)
Placeholder until we address bug 15786 (implementing a proper exception hierarchy).
|
AMQCommand |
AMQChannel.rpc(Method m)
Protected API - sends a
Method to the broker and waits for the
next in-bound Command from the broker: only for use from
non-connection-MainLoop threads! |
AMQCommand |
ChannelN.rpc(Method method) |
AMQCommand |
AMQChannel.rpc(Method m,
int timeout) |
AMQCommand |
AMQChannel.SimpleBlockingRpcContinuation.transformReply(AMQCommand command) |
Modifier and Type | Method and Description |
---|---|
boolean |
AMQChannel.RpcContinuation.canHandleReply(AMQCommand command) |
boolean |
AMQChannel.BlockingRpcContinuation.canHandleReply(AMQCommand command) |
boolean |
RpcContinuationRpcWrapper.canHandleReply(AMQCommand command) |
boolean |
CompletableFutureRpcWrapper.canHandleReply(AMQCommand command) |
boolean |
RpcWrapper.canHandleReply(AMQCommand command) |
void |
RpcContinuationRpcWrapper.complete(AMQCommand command) |
void |
CompletableFutureRpcWrapper.complete(AMQCommand command) |
void |
RpcWrapper.complete(AMQCommand command) |
void |
AMQChannel.RpcContinuation.handleCommand(AMQCommand command) |
void |
AMQChannel.BlockingRpcContinuation.handleCommand(AMQCommand command) |
void |
AMQChannel.handleCompleteInboundCommand(AMQCommand command)
Private API - handle a command which has been assembled
|
void |
AMQChannel.quiescingTransmit(AMQCommand c) |
abstract T |
AMQChannel.BlockingRpcContinuation.transformReply(AMQCommand command) |
AMQCommand |
AMQChannel.SimpleBlockingRpcContinuation.transformReply(AMQCommand command) |
void |
AMQChannel.transmit(AMQCommand c) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.