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 MethodUnexpectedMethodError. _methodprivate MethodShutdownSignalException. _reasonPossible explanationprivate MethodChannelContinuationTimeoutException. methodThe request method that timed out.Methods in com.rabbitmq.client that return Method Modifier and Type Method Description MethodChannelContinuationTimeoutException. getMethod()MethodCommand. getMethod()Retrieves theMethodheld within this Command.MethodUnexpectedMethodError. getMethod()Return the wrapped method.MethodShutdownSignalException. 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.voidChannel. asyncRpc(Method method)Asynchronously send a method over this channel.private static java.lang.StringShutdownSignalException. composeMessage(boolean hardError, boolean initiatedByApplication, Method reason, java.lang.String messagePrefix, java.lang.Throwable cause)CommandChannel. 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 MethodAMQChannel.BlockingRpcContinuation. requestprivate MethodCompletableFutureRpcWrapper. requestMethods in com.rabbitmq.client.impl with parameters of type Method Modifier and Type Method Description java.util.concurrent.CompletableFuture<Command>ChannelN. asyncCompletableRpc(Method method)voidAMQChannel. asyncRpc(Method m, java.util.concurrent.CompletableFuture<Command> future)voidChannelN. asyncRpc(Method method)voidAMQChannel. enqueueAsyncRpc(Method method, java.util.concurrent.CompletableFuture<Command> future)java.util.concurrent.CompletableFuture<Command>AMQChannel. exnWrappingAsyncRpc(Method m)AMQCommandAMQChannel. exnWrappingRpc(Method m)Placeholder until we address bug 15786 (implementing a proper exception hierarchy).static booleanAMQChannel.BlockingRpcContinuation. isResponseCompatibleWithRequest(Method request, Method response)private java.util.concurrent.CompletableFuture<Command>AMQChannel. privateAsyncRpc(Method m)private AMQCommandAMQChannel. privateRpc(Method m)private AMQCommandAMQChannel. privateRpc(Method m, int timeout)voidAMQChannel. quiescingAsyncRpc(Method m, java.util.concurrent.CompletableFuture<Command> future)voidAMQChannel. quiescingRpc(Method m, AMQChannel.RpcContinuation k)voidAMQChannel. quiescingTransmit(Method m)AMQCommandAMQChannel. rpc(Method m)Protected API - sends aMethodto the broker and waits for the next in-bound Command from the broker: only for use from non-connection-MainLoop threads!AMQCommandAMQChannel. rpc(Method m, int timeout)voidAMQChannel. rpc(Method m, AMQChannel.RpcContinuation k)AMQCommandChannelN. rpc(Method method)ShutdownSignalExceptionAMQConnection. 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 ShutdownSignalExceptionAMQConnection. startShutdown(Method reason, boolean initiatedByApplication, java.lang.Throwable cause, boolean notifyRpc)voidAMQChannel. transmit(Method m)protected ChannelContinuationTimeoutExceptionAMQChannel. 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)voidAutorecoveringChannel. asyncRpc(Method method)private voidAutorecoveringChannel. recordOnRpcRequest(Method method)private voidAutorecoveringChannel. recordOnRpcResponse(Method response, Method request)CommandAutorecoveringChannel. rpc(Method method)
-