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 |
---|---|
Method |
UnexpectedMethodError.getMethod()
Return the wrapped method.
|
Method |
ChannelContinuationTimeoutException.getMethod() |
Method |
Command.getMethod()
Retrieves the
Method held within this Command. |
Method |
ShutdownSignalException.getReason() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Command> |
Channel.asyncCompletableRpc(Method method)
Asynchronously send a method over this channel.
|
void |
Channel.asyncRpc(Method method)
Asynchronously send a method over this channel.
|
Command |
Channel.rpc(Method method)
Synchronously send a method over this channel.
|
Constructor and Description |
---|
ChannelContinuationTimeoutException(TimeoutException cause,
Object channel,
int channelNumber,
Method method) |
ShutdownSignalException(boolean hardError,
boolean initiatedByApplication,
Method reason,
Object ref)
Construct a ShutdownSignalException from the arguments.
|
ShutdownSignalException(boolean hardError,
boolean initiatedByApplication,
Method reason,
Object ref,
String messagePrefix,
Throwable cause)
Construct a ShutdownSignalException from the arguments.
|
UnexpectedMethodError(Method method)
Construct an UnexpectedMethodError with the given method parameter
|
Modifier and Type | Field and Description |
---|---|
protected Method |
AMQChannel.BlockingRpcContinuation.request |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Command> |
ChannelN.asyncCompletableRpc(Method method) |
void |
ChannelN.asyncRpc(Method method) |
void |
AMQChannel.asyncRpc(Method m,
CompletableFuture<Command> future) |
void |
AMQChannel.enqueueAsyncRpc(Method method,
CompletableFuture<Command> future) |
CompletableFuture<Command> |
AMQChannel.exnWrappingAsyncRpc(Method m) |
AMQCommand |
AMQChannel.exnWrappingRpc(Method m)
Placeholder until we address bug 15786 (implementing a proper exception hierarchy).
|
static boolean |
AMQChannel.BlockingRpcContinuation.isResponseCompatibleWithRequest(Method request,
Method response) |
void |
AMQChannel.quiescingAsyncRpc(Method m,
CompletableFuture<Command> future) |
void |
AMQChannel.quiescingRpc(Method m,
AMQChannel.RpcContinuation k) |
void |
AMQChannel.quiescingTransmit(Method m) |
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) |
void |
AMQChannel.rpc(Method m,
AMQChannel.RpcContinuation k) |
AMQCommand |
AMQChannel.rpc(Method m,
int timeout) |
ShutdownSignalException |
AMQConnection.shutdown(Method reason,
boolean initiatedByApplication,
Throwable cause,
boolean notifyRpc)
Protected API - causes all attached channels to terminate (shutdown) with a ShutdownSignal
built from the argument, and stops this connection from accepting further work from the
application.
|
void |
AMQChannel.transmit(Method m) |
protected ChannelContinuationTimeoutException |
AMQChannel.wrapTimeoutException(Method m,
TimeoutException e)
Cleans RPC channel state after a timeout and wraps the TimeoutException in a ChannelContinuationTimeoutException
|
Constructor and Description |
---|
AMQCommand(Method method)
Construct a command with just a method, and without header or body.
|
AMQCommand(Method method,
AMQContentHeader contentHeader,
byte[] body)
Construct a command with a specified method, header and body.
|
BlockingRpcContinuation(Method request) |
CompletableFutureRpcWrapper(Method method,
CompletableFuture<Command> completableFuture) |
SimpleBlockingRpcContinuation(Method method) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Command> |
AutorecoveringChannel.asyncCompletableRpc(Method method) |
void |
AutorecoveringChannel.asyncRpc(Method method) |
Command |
AutorecoveringChannel.rpc(Method method) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.