Uses of Interface
com.rabbitmq.client.Method
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 Method in com.rabbitmq.client
Modifier and TypeInterfaceDescriptionstatic interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
static interface
Modifier and TypeMethodDescriptionChannelContinuationTimeoutException.getMethod()
Command.getMethod()
Retrieves theMethod
held within this Command.UnexpectedMethodError.getMethod()
Return the wrapped method.ShutdownSignalException.getReason()
Modifier and TypeMethodDescriptionChannel.asyncCompletableRpc
(Method method) Asynchronously send a method over this channel.void
Asynchronously send a method over this channel.Synchronously send a method over this channel.ModifierConstructorDescriptionChannelContinuationTimeoutException
(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 -
Uses of Method in com.rabbitmq.client.impl
Modifier and TypeClassDescriptionstatic class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
class
Base class for AMQP method objects, specialized by autogenerated code in AMQP.java.Modifier and TypeFieldDescriptionprotected final Method
AMQChannel.BlockingRpcContinuation.request
Modifier and TypeMethodDescriptionChannelN.asyncCompletableRpc
(Method method) void
AMQChannel.asyncRpc
(Method m, CompletableFuture<Command> future) void
void
AMQChannel.enqueueAsyncRpc
(Method method, CompletableFuture<Command> future) AMQChannel.exnWrappingAsyncRpc
(Method m) 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) 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!void
AMQChannel.rpc
(Method m, AMQChannel.RpcContinuation k) 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
protected ChannelContinuationTimeoutException
AMQChannel.wrapTimeoutException
(Method m, TimeoutException e) Cleans RPC channel state after a timeout and wraps the TimeoutException in a ChannelContinuationTimeoutExceptionModifierConstructorDescriptionAMQCommand
(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.AMQCommand
(Method method, AMQContentHeader contentHeader, byte[] body, int maxBodyLength) Construct a command with a specified method, header and body.BlockingRpcContinuation
(Method request) CompletableFutureRpcWrapper
(Method method, CompletableFuture<Command> completableFuture) SimpleBlockingRpcContinuation
(Method method) -
Uses of Method in com.rabbitmq.client.impl.recovery