Uses of Interface
com.rabbitmq.client.Method
-
Packages that use Method 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. -
-
Uses of Method in com.rabbitmq.client
Fields in com.rabbitmq.client declared as Method Modifier and Type Field Description private Method
UnexpectedMethodError. _method
private Method
ShutdownSignalException. _reason
Possible explanationprivate Method
ChannelContinuationTimeoutException. method
The request method that timed out.Methods in com.rabbitmq.client that return Method Modifier and Type Method Description Method
ChannelContinuationTimeoutException. getMethod()
Method
Command. getMethod()
Retrieves theMethod
held within this Command.Method
UnexpectedMethodError. getMethod()
Return the wrapped method.Method
ShutdownSignalException. getReason()
Methods in com.rabbitmq.client with parameters of type Method Modifier and Type Method Description java.util.concurrent.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.private static java.lang.String
ShutdownSignalException. composeMessage(boolean hardError, boolean initiatedByApplication, Method reason, java.lang.String messagePrefix, java.lang.Throwable cause)
Command
Channel. rpc(Method method)
Synchronously send a method over this channel.Constructors in com.rabbitmq.client with parameters of type Method Constructor Description ChannelContinuationTimeoutException(java.util.concurrent.TimeoutException cause, java.lang.Object channel, int channelNumber, Method method)
ShutdownSignalException(boolean hardError, boolean initiatedByApplication, Method reason, java.lang.Object ref)
Construct a ShutdownSignalException from the arguments.ShutdownSignalException(boolean hardError, boolean initiatedByApplication, Method reason, java.lang.Object ref, java.lang.String messagePrefix, java.lang.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
Fields in com.rabbitmq.client.impl declared as Method Modifier and Type Field Description protected Method
AMQChannel.BlockingRpcContinuation. request
private Method
CompletableFutureRpcWrapper. request
Methods in com.rabbitmq.client.impl with parameters of type Method Modifier and Type Method Description java.util.concurrent.CompletableFuture<Command>
ChannelN. asyncCompletableRpc(Method method)
void
AMQChannel. asyncRpc(Method m, java.util.concurrent.CompletableFuture<Command> future)
void
ChannelN. asyncRpc(Method method)
void
AMQChannel. enqueueAsyncRpc(Method method, java.util.concurrent.CompletableFuture<Command> future)
java.util.concurrent.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)
private java.util.concurrent.CompletableFuture<Command>
AMQChannel. privateAsyncRpc(Method m)
private AMQCommand
AMQChannel. privateRpc(Method m)
private AMQCommand
AMQChannel. privateRpc(Method m, int timeout)
void
AMQChannel. quiescingAsyncRpc(Method m, java.util.concurrent.CompletableFuture<Command> future)
void
AMQChannel. quiescingRpc(Method m, AMQChannel.RpcContinuation k)
void
AMQChannel. quiescingTransmit(Method m)
AMQCommand
AMQChannel. rpc(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!AMQCommand
AMQChannel. rpc(Method m, int timeout)
void
AMQChannel. rpc(Method m, AMQChannel.RpcContinuation k)
AMQCommand
ChannelN. rpc(Method method)
ShutdownSignalException
AMQConnection. shutdown(Method reason, boolean initiatedByApplication, java.lang.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.private ShutdownSignalException
AMQConnection. startShutdown(Method reason, boolean initiatedByApplication, java.lang.Throwable cause, boolean notifyRpc)
void
AMQChannel. transmit(Method m)
protected ChannelContinuationTimeoutException
AMQChannel. wrapTimeoutException(Method m, java.util.concurrent.TimeoutException e)
Cleans RPC channel state after a timeout and wraps the TimeoutException in a ChannelContinuationTimeoutExceptionConstructors in com.rabbitmq.client.impl with parameters of type Method Constructor 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.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, java.util.concurrent.CompletableFuture<Command> completableFuture)
SimpleBlockingRpcContinuation(Method method)
-
Uses of Method in com.rabbitmq.client.impl.recovery
Methods in com.rabbitmq.client.impl.recovery with parameters of type Method Modifier and Type Method Description java.util.concurrent.CompletableFuture<Command>
AutorecoveringChannel. asyncCompletableRpc(Method method)
void
AutorecoveringChannel. asyncRpc(Method method)
private void
AutorecoveringChannel. recordOnRpcRequest(Method method)
private void
AutorecoveringChannel. recordOnRpcResponse(Method response, Method request)
Command
AutorecoveringChannel. rpc(Method method)
-