Index (RabbitMQ Java Client 5.17.0 API)

A B C D E F G H I J K L M N O P Q R S T U V W _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

abort() - Method in interface com.rabbitmq.client.Channel: Abort this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in interface com.rabbitmq.client.Connection: Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Abort this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
abort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
abort(int) - Method in interface com.rabbitmq.client.Connection: Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort(int) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort(int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
abort(int, String) - Method in interface com.rabbitmq.client.Channel: Abort this channel.
abort(int, String) - Method in interface com.rabbitmq.client.Connection: Abort this connection and all its channels.
abort(int, String) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Abort this connection and all its channels.
abort(int, String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Abort this channel.
abort(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
abort(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
abort(int, String, int) - Method in interface com.rabbitmq.client.Connection: Abort this connection and all its channels.
abort(int, String, int) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Abort this connection and all its channels.
abort(int, String, int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
AbstractFrameHandlerFactory - Class in com.rabbitmq.client.impl
AbstractFrameHandlerFactory(int, SocketConfigurator, boolean) - Constructor for class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
AbstractMetricsCollector - Class in com.rabbitmq.client.impl: Base class for MetricsCollector.
AbstractMetricsCollector() - Constructor for class com.rabbitmq.client.impl.AbstractMetricsCollector
Access() - Constructor for class com.rabbitmq.client.AMQP.Access
Access() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Access
ACCESS_REFUSED - Static variable in interface com.rabbitmq.client.AMQP
Ack(long, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
Ack(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
ACKED_PUBLISHED_MESSAGES - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
ACKNOWLEDGED_MESSAGES - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
active() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
active() - Method in class com.rabbitmq.client.AMQP.Channel.Flow.Builder
active() - Method in class com.rabbitmq.client.AMQP.Channel.FlowOk.Builder
active(boolean) - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
active(boolean) - Method in class com.rabbitmq.client.AMQP.Channel.Flow.Builder
active(boolean) - Method in class com.rabbitmq.client.AMQP.Channel.FlowOk.Builder
add(SocketChannelConfigurator) - Method in class com.rabbitmq.client.SocketChannelConfigurators.Builder: Add an extra configuration step.
add(SocketConfigurator) - Method in class com.rabbitmq.client.SocketConfigurators.Builder: Add an extra configuration step.
add(SslEngineConfigurator) - Method in class com.rabbitmq.client.SslEngineConfigurators.Builder: Add extra configuration step.
addBlockedListener(BlockedCallback, UnblockedCallback) - Method in interface com.rabbitmq.client.Connection: Add a lambda-based BlockedListener.
addBlockedListener(BlockedCallback, UnblockedCallback) - Method in class com.rabbitmq.client.impl.AMQConnection
addBlockedListener(BlockedCallback, UnblockedCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
addBlockedListener(BlockedListener) - Method in interface com.rabbitmq.client.Connection: Add a BlockedListener.
addBlockedListener(BlockedListener) - Method in class com.rabbitmq.client.impl.AMQConnection
addBlockedListener(BlockedListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
addConfirmListener(ConfirmCallback, ConfirmCallback) - Method in interface com.rabbitmq.client.Channel: Add a lambda-based ConfirmListener.
addConfirmListener(ConfirmCallback, ConfirmCallback) - Method in class com.rabbitmq.client.impl.ChannelN
addConfirmListener(ConfirmCallback, ConfirmCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
addConfirmListener(ConfirmListener) - Method in interface com.rabbitmq.client.Channel: Add a ConfirmListener.
addConfirmListener(ConfirmListener) - Method in class com.rabbitmq.client.impl.ChannelN
addConfirmListener(ConfirmListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
addConsumerRecoveryListener(ConsumerRecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Not part of the public API.
addIfNotPresent(T) - Method in class com.rabbitmq.client.impl.SetQueue: Add an element to the back of the queue and return true, or else return false.
addQueueRecoveryListener(QueueRecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Not part of the public API.
addRecoveryCanBeginListener(RecoveryCanBeginListener) - Method in class com.rabbitmq.client.impl.AMQConnection
addRecoveryListener(RecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
addRecoveryListener(RecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Adds the recovery listener
addRecoveryListener(RecoveryListener) - Method in interface com.rabbitmq.client.Recoverable: Registers a connection recovery callback.
Address - Class in com.rabbitmq.client: A representation of network addresses, i.e.
Address(String) - Constructor for class com.rabbitmq.client.Address: Construct an address from a host.
Address(String, int) - Constructor for class com.rabbitmq.client.Address: Construct an address from a host name and port number.
AddressResolver - Interface in com.rabbitmq.client: Strategy interface to get the potential servers to connect to.
addReturnListener(ReturnCallback) - Method in interface com.rabbitmq.client.Channel: Add a lambda-based ReturnListener.
addReturnListener(ReturnCallback) - Method in class com.rabbitmq.client.impl.ChannelN
addReturnListener(ReturnCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
addReturnListener(ReturnListener) - Method in interface com.rabbitmq.client.Channel: Add a ReturnListener.
addReturnListener(ReturnListener) - Method in class com.rabbitmq.client.impl.ChannelN
addReturnListener(ReturnListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
addShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
addShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
addShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
addShutdownListener(ShutdownListener) - Method in interface com.rabbitmq.client.ShutdownNotifier: Add shutdown listener.
addWork(Channel, Runnable) - Method in class com.rabbitmq.client.impl.ConsumerWorkService
addWorkItem(K, W) - Method in class com.rabbitmq.client.impl.WorkPool: Add (enqueue) an item for a specific client.
adjust() - Method in class com.rabbitmq.client.impl.Version: Adjust a version for spec weirdness.
allocate() - Method in class com.rabbitmq.utility.IntAllocator: Allocate an unallocated integer from the range, or return -1 if no more integers are available.
AlreadyClosedException - Exception in com.rabbitmq.client: Thrown when application tries to perform an action on connection/channel which was already closed
AlreadyClosedException(ShutdownSignalException) - Constructor for exception com.rabbitmq.client.AlreadyClosedException
AlreadyClosedException(ShutdownSignalException, Throwable) - Constructor for exception com.rabbitmq.client.AlreadyClosedException
AMQBasicProperties - Class in com.rabbitmq.client.impl
AMQBasicProperties() - Constructor for class com.rabbitmq.client.impl.AMQBasicProperties
AMQBasicProperties(DataInputStream) - Constructor for class com.rabbitmq.client.impl.AMQBasicProperties
AMQChannel - Class in com.rabbitmq.client.impl: Base class modelling an AMQ channel.
AMQChannel(AMQConnection, int) - Constructor for class com.rabbitmq.client.impl.AMQChannel: Construct a channel on the given connection, with the given channel number.
AMQChannel.BlockingRpcContinuation<T> - Class in com.rabbitmq.client.impl
AMQChannel.RpcContinuation - Interface in com.rabbitmq.client.impl
AMQChannel.SimpleBlockingRpcContinuation - Class in com.rabbitmq.client.impl
AMQCommand - Class in com.rabbitmq.client.impl: AMQP 0-9-1-specific implementation of Command which accumulates method, header and body from a series of frames, unless these are supplied at construction time.
AMQCommand() - Constructor for class com.rabbitmq.client.impl.AMQCommand: Construct a command ready to fill in by reading frames
AMQCommand(Method) - Constructor for class com.rabbitmq.client.impl.AMQCommand: Construct a command with just a method, and without header or body.
AMQCommand(Method, AMQContentHeader, byte[]) - Constructor for class com.rabbitmq.client.impl.AMQCommand: Construct a command with a specified method, header and body.
AMQConnection - Class in com.rabbitmq.client.impl: Concrete class representing and managing an AMQP connection to a broker.
AMQConnection(ConnectionParams, FrameHandler) - Constructor for class com.rabbitmq.client.impl.AMQConnection
AMQConnection(ConnectionParams, FrameHandler, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.AMQConnection: Construct a new connection
AMQContentHeader - Class in com.rabbitmq.client.impl: Implementation of ContentHeader - specialized by autogenerated code in AMQP.java.
AMQContentHeader() - Constructor for class com.rabbitmq.client.impl.AMQContentHeader
AMQContentHeader(DataInputStream) - Constructor for class com.rabbitmq.client.impl.AMQContentHeader
AMQImpl - Class in com.rabbitmq.client.impl
AMQImpl() - Constructor for class com.rabbitmq.client.impl.AMQImpl
AMQImpl.Access - Class in com.rabbitmq.client.impl
AMQImpl.Access.Request - Class in com.rabbitmq.client.impl
AMQImpl.Access.RequestOk - Class in com.rabbitmq.client.impl
AMQImpl.Basic - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Ack - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Cancel - Class in com.rabbitmq.client.impl
AMQImpl.Basic.CancelOk - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Consume - Class in com.rabbitmq.client.impl
AMQImpl.Basic.ConsumeOk - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Deliver - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Get - Class in com.rabbitmq.client.impl
AMQImpl.Basic.GetEmpty - Class in com.rabbitmq.client.impl
AMQImpl.Basic.GetOk - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Nack - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Publish - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Qos - Class in com.rabbitmq.client.impl
AMQImpl.Basic.QosOk - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Recover - Class in com.rabbitmq.client.impl
AMQImpl.Basic.RecoverAsync - Class in com.rabbitmq.client.impl
AMQImpl.Basic.RecoverOk - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Reject - Class in com.rabbitmq.client.impl
AMQImpl.Basic.Return - Class in com.rabbitmq.client.impl
AMQImpl.Channel - Class in com.rabbitmq.client.impl
AMQImpl.Channel.Close - Class in com.rabbitmq.client.impl
AMQImpl.Channel.CloseOk - Class in com.rabbitmq.client.impl
AMQImpl.Channel.Flow - Class in com.rabbitmq.client.impl
AMQImpl.Channel.FlowOk - Class in com.rabbitmq.client.impl
AMQImpl.Channel.Open - Class in com.rabbitmq.client.impl
AMQImpl.Channel.OpenOk - Class in com.rabbitmq.client.impl
AMQImpl.Confirm - Class in com.rabbitmq.client.impl
AMQImpl.Confirm.Select - Class in com.rabbitmq.client.impl
AMQImpl.Confirm.SelectOk - Class in com.rabbitmq.client.impl
AMQImpl.Connection - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Blocked - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Close - Class in com.rabbitmq.client.impl
AMQImpl.Connection.CloseOk - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Open - Class in com.rabbitmq.client.impl
AMQImpl.Connection.OpenOk - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Secure - Class in com.rabbitmq.client.impl
AMQImpl.Connection.SecureOk - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Start - Class in com.rabbitmq.client.impl
AMQImpl.Connection.StartOk - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Tune - Class in com.rabbitmq.client.impl
AMQImpl.Connection.TuneOk - Class in com.rabbitmq.client.impl
AMQImpl.Connection.Unblocked - Class in com.rabbitmq.client.impl
AMQImpl.Connection.UpdateSecret - Class in com.rabbitmq.client.impl
AMQImpl.Connection.UpdateSecretOk - Class in com.rabbitmq.client.impl
AMQImpl.DefaultMethodVisitor - Class in com.rabbitmq.client.impl
AMQImpl.Exchange - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.Bind - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.BindOk - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.Declare - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.DeclareOk - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.Delete - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.DeleteOk - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.Unbind - Class in com.rabbitmq.client.impl
AMQImpl.Exchange.UnbindOk - Class in com.rabbitmq.client.impl
AMQImpl.MethodVisitor - Interface in com.rabbitmq.client.impl
AMQImpl.Queue - Class in com.rabbitmq.client.impl
AMQImpl.Queue.Bind - Class in com.rabbitmq.client.impl
AMQImpl.Queue.BindOk - Class in com.rabbitmq.client.impl
AMQImpl.Queue.Declare - Class in com.rabbitmq.client.impl
AMQImpl.Queue.DeclareOk - Class in com.rabbitmq.client.impl
AMQImpl.Queue.Delete - Class in com.rabbitmq.client.impl
AMQImpl.Queue.DeleteOk - Class in com.rabbitmq.client.impl
AMQImpl.Queue.Purge - Class in com.rabbitmq.client.impl
AMQImpl.Queue.PurgeOk - Class in com.rabbitmq.client.impl
AMQImpl.Queue.Unbind - Class in com.rabbitmq.client.impl
AMQImpl.Queue.UnbindOk - Class in com.rabbitmq.client.impl
AMQImpl.Tx - Class in com.rabbitmq.client.impl
AMQImpl.Tx.Commit - Class in com.rabbitmq.client.impl
AMQImpl.Tx.CommitOk - Class in com.rabbitmq.client.impl
AMQImpl.Tx.Rollback - Class in com.rabbitmq.client.impl
AMQImpl.Tx.RollbackOk - Class in com.rabbitmq.client.impl
AMQImpl.Tx.Select - Class in com.rabbitmq.client.impl
AMQImpl.Tx.SelectOk - Class in com.rabbitmq.client.impl
AMQP - Interface in com.rabbitmq.client
AMQP.Access - Class in com.rabbitmq.client
AMQP.Access.Request - Interface in com.rabbitmq.client
AMQP.Access.Request.Builder - Class in com.rabbitmq.client
AMQP.Access.RequestOk - Interface in com.rabbitmq.client
AMQP.Access.RequestOk.Builder - Class in com.rabbitmq.client
AMQP.Basic - Class in com.rabbitmq.client
AMQP.Basic.Ack - Interface in com.rabbitmq.client
AMQP.Basic.Ack.Builder - Class in com.rabbitmq.client
AMQP.Basic.Cancel - Interface in com.rabbitmq.client
AMQP.Basic.Cancel.Builder - Class in com.rabbitmq.client
AMQP.Basic.CancelOk - Interface in com.rabbitmq.client
AMQP.Basic.CancelOk.Builder - Class in com.rabbitmq.client
AMQP.Basic.Consume - Interface in com.rabbitmq.client
AMQP.Basic.Consume.Builder - Class in com.rabbitmq.client
AMQP.Basic.ConsumeOk - Interface in com.rabbitmq.client
AMQP.Basic.ConsumeOk.Builder - Class in com.rabbitmq.client
AMQP.Basic.Deliver - Interface in com.rabbitmq.client
AMQP.Basic.Deliver.Builder - Class in com.rabbitmq.client
AMQP.Basic.Get - Interface in com.rabbitmq.client
AMQP.Basic.Get.Builder - Class in com.rabbitmq.client
AMQP.Basic.GetEmpty - Interface in com.rabbitmq.client
AMQP.Basic.GetEmpty.Builder - Class in com.rabbitmq.client
AMQP.Basic.GetOk - Interface in com.rabbitmq.client
AMQP.Basic.GetOk.Builder - Class in com.rabbitmq.client
AMQP.Basic.Nack - Interface in com.rabbitmq.client
AMQP.Basic.Nack.Builder - Class in com.rabbitmq.client
AMQP.Basic.Publish - Interface in com.rabbitmq.client
AMQP.Basic.Publish.Builder - Class in com.rabbitmq.client
AMQP.Basic.Qos - Interface in com.rabbitmq.client
AMQP.Basic.Qos.Builder - Class in com.rabbitmq.client
AMQP.Basic.QosOk - Interface in com.rabbitmq.client
AMQP.Basic.QosOk.Builder - Class in com.rabbitmq.client
AMQP.Basic.Recover - Interface in com.rabbitmq.client
AMQP.Basic.Recover.Builder - Class in com.rabbitmq.client
AMQP.Basic.RecoverAsync - Interface in com.rabbitmq.client
AMQP.Basic.RecoverAsync.Builder - Class in com.rabbitmq.client
AMQP.Basic.RecoverOk - Interface in com.rabbitmq.client
AMQP.Basic.RecoverOk.Builder - Class in com.rabbitmq.client
AMQP.Basic.Reject - Interface in com.rabbitmq.client
AMQP.Basic.Reject.Builder - Class in com.rabbitmq.client
AMQP.Basic.Return - Interface in com.rabbitmq.client
AMQP.Basic.Return.Builder - Class in com.rabbitmq.client
AMQP.BasicProperties - Class in com.rabbitmq.client
AMQP.BasicProperties.Builder - Class in com.rabbitmq.client
AMQP.Channel - Class in com.rabbitmq.client
AMQP.Channel.Close - Interface in com.rabbitmq.client
AMQP.Channel.Close.Builder - Class in com.rabbitmq.client
AMQP.Channel.CloseOk - Interface in com.rabbitmq.client
AMQP.Channel.CloseOk.Builder - Class in com.rabbitmq.client
AMQP.Channel.Flow - Interface in com.rabbitmq.client
AMQP.Channel.Flow.Builder - Class in com.rabbitmq.client
AMQP.Channel.FlowOk - Interface in com.rabbitmq.client
AMQP.Channel.FlowOk.Builder - Class in com.rabbitmq.client
AMQP.Channel.Open - Interface in com.rabbitmq.client
AMQP.Channel.Open.Builder - Class in com.rabbitmq.client
AMQP.Channel.OpenOk - Interface in com.rabbitmq.client
AMQP.Channel.OpenOk.Builder - Class in com.rabbitmq.client
AMQP.Confirm - Class in com.rabbitmq.client
AMQP.Confirm.Select - Interface in com.rabbitmq.client
AMQP.Confirm.Select.Builder - Class in com.rabbitmq.client
AMQP.Confirm.SelectOk - Interface in com.rabbitmq.client
AMQP.Confirm.SelectOk.Builder - Class in com.rabbitmq.client
AMQP.Connection - Class in com.rabbitmq.client
AMQP.Connection.Blocked - Interface in com.rabbitmq.client
AMQP.Connection.Blocked.Builder - Class in com.rabbitmq.client
AMQP.Connection.Close - Interface in com.rabbitmq.client
AMQP.Connection.Close.Builder - Class in com.rabbitmq.client
AMQP.Connection.CloseOk - Interface in com.rabbitmq.client
AMQP.Connection.CloseOk.Builder - Class in com.rabbitmq.client
AMQP.Connection.Open - Interface in com.rabbitmq.client
AMQP.Connection.Open.Builder - Class in com.rabbitmq.client
AMQP.Connection.OpenOk - Interface in com.rabbitmq.client
AMQP.Connection.OpenOk.Builder - Class in com.rabbitmq.client
AMQP.Connection.Secure - Interface in com.rabbitmq.client
AMQP.Connection.Secure.Builder - Class in com.rabbitmq.client
AMQP.Connection.SecureOk - Interface in com.rabbitmq.client
AMQP.Connection.SecureOk.Builder - Class in com.rabbitmq.client
AMQP.Connection.Start - Interface in com.rabbitmq.client
AMQP.Connection.Start.Builder - Class in com.rabbitmq.client
AMQP.Connection.StartOk - Interface in com.rabbitmq.client
AMQP.Connection.StartOk.Builder - Class in com.rabbitmq.client
AMQP.Connection.Tune - Interface in com.rabbitmq.client
AMQP.Connection.Tune.Builder - Class in com.rabbitmq.client
AMQP.Connection.TuneOk - Interface in com.rabbitmq.client
AMQP.Connection.TuneOk.Builder - Class in com.rabbitmq.client
AMQP.Connection.Unblocked - Interface in com.rabbitmq.client
AMQP.Connection.Unblocked.Builder - Class in com.rabbitmq.client
AMQP.Connection.UpdateSecret - Interface in com.rabbitmq.client
AMQP.Connection.UpdateSecret.Builder - Class in com.rabbitmq.client
AMQP.Connection.UpdateSecretOk - Interface in com.rabbitmq.client
AMQP.Connection.UpdateSecretOk.Builder - Class in com.rabbitmq.client
AMQP.Exchange - Class in com.rabbitmq.client
AMQP.Exchange.Bind - Interface in com.rabbitmq.client
AMQP.Exchange.Bind.Builder - Class in com.rabbitmq.client
AMQP.Exchange.BindOk - Interface in com.rabbitmq.client
AMQP.Exchange.BindOk.Builder - Class in com.rabbitmq.client
AMQP.Exchange.Declare - Interface in com.rabbitmq.client
AMQP.Exchange.Declare.Builder - Class in com.rabbitmq.client
AMQP.Exchange.DeclareOk - Interface in com.rabbitmq.client
AMQP.Exchange.DeclareOk.Builder - Class in com.rabbitmq.client
AMQP.Exchange.Delete - Interface in com.rabbitmq.client
AMQP.Exchange.Delete.Builder - Class in com.rabbitmq.client
AMQP.Exchange.DeleteOk - Interface in com.rabbitmq.client
AMQP.Exchange.DeleteOk.Builder - Class in com.rabbitmq.client
AMQP.Exchange.Unbind - Interface in com.rabbitmq.client
AMQP.Exchange.Unbind.Builder - Class in com.rabbitmq.client
AMQP.Exchange.UnbindOk - Interface in com.rabbitmq.client
AMQP.Exchange.UnbindOk.Builder - Class in com.rabbitmq.client
AMQP.PROTOCOL - Class in com.rabbitmq.client
AMQP.Queue - Class in com.rabbitmq.client
AMQP.Queue.Bind - Interface in com.rabbitmq.client
AMQP.Queue.Bind.Builder - Class in com.rabbitmq.client
AMQP.Queue.BindOk - Interface in com.rabbitmq.client
AMQP.Queue.BindOk.Builder - Class in com.rabbitmq.client
AMQP.Queue.Declare - Interface in com.rabbitmq.client
AMQP.Queue.Declare.Builder - Class in com.rabbitmq.client
AMQP.Queue.DeclareOk - Interface in com.rabbitmq.client
AMQP.Queue.DeclareOk.Builder - Class in com.rabbitmq.client
AMQP.Queue.Delete - Interface in com.rabbitmq.client
AMQP.Queue.Delete.Builder - Class in com.rabbitmq.client
AMQP.Queue.DeleteOk - Interface in com.rabbitmq.client
AMQP.Queue.DeleteOk.Builder - Class in com.rabbitmq.client
AMQP.Queue.Purge - Interface in com.rabbitmq.client
AMQP.Queue.Purge.Builder - Class in com.rabbitmq.client
AMQP.Queue.PurgeOk - Interface in com.rabbitmq.client
AMQP.Queue.PurgeOk.Builder - Class in com.rabbitmq.client
AMQP.Queue.Unbind - Interface in com.rabbitmq.client
AMQP.Queue.Unbind.Builder - Class in com.rabbitmq.client
AMQP.Queue.UnbindOk - Interface in com.rabbitmq.client
AMQP.Queue.UnbindOk.Builder - Class in com.rabbitmq.client
AMQP.Tx - Class in com.rabbitmq.client
AMQP.Tx.Commit - Interface in com.rabbitmq.client
AMQP.Tx.Commit.Builder - Class in com.rabbitmq.client
AMQP.Tx.CommitOk - Interface in com.rabbitmq.client
AMQP.Tx.CommitOk.Builder - Class in com.rabbitmq.client
AMQP.Tx.Rollback - Interface in com.rabbitmq.client
AMQP.Tx.Rollback.Builder - Class in com.rabbitmq.client
AMQP.Tx.RollbackOk - Interface in com.rabbitmq.client
AMQP.Tx.RollbackOk.Builder - Class in com.rabbitmq.client
AMQP.Tx.Select - Interface in com.rabbitmq.client
AMQP.Tx.Select.Builder - Class in com.rabbitmq.client
AMQP.Tx.SelectOk - Interface in com.rabbitmq.client
AMQP.Tx.SelectOk.Builder - Class in com.rabbitmq.client
andThen(DefaultRetryHandler.RetryOperation<V>) - Method in interface com.rabbitmq.client.impl.recovery.DefaultRetryHandler.RetryOperation
andThen(SocketChannelConfigurator) - Method in interface com.rabbitmq.client.SocketChannelConfigurator: Returns a composed configurator that performs, in sequence, this operation followed by the after operation.
andThen(SocketConfigurator) - Method in interface com.rabbitmq.client.SocketConfigurator: Returns a composed configurator that performs, in sequence, this operation followed by the after operation.
andThen(SslEngineConfigurator) - Method in interface com.rabbitmq.client.SslEngineConfigurator: Returns a composed configurator that performs, in sequence, this operation followed by the after operation.
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecretOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
appendArgumentDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.Method: Public API - debugging utility
appendPropertyDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.AMQP.BasicProperties
appendPropertyDebugStringTo(StringBuilder) - Method in interface com.rabbitmq.client.ContentHeader: A debugging utility - enable properties to be appended to a string buffer for use as trace messages.
appendPropertyDebugStringTo(StringBuilder) - Method in class com.rabbitmq.client.impl.AMQContentHeader: Public API - A debugging utility - enable properties to be appended to a string buffer for use as trace messages.
appId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
applicationBuffer - Variable in class com.rabbitmq.client.impl.nio.FrameBuilder
approachingExpirationStrategy(Function<Duration, Boolean>) - Method in class com.rabbitmq.client.impl.DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder: Set the strategy to trigger an early refresh before attempting to connect.
arguments - Variable in class com.rabbitmq.client.impl.recovery.RecordedBinding
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
arity() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription: Retrieves the parameter count for this procedure
arraySize(Object[]) - Static method in class com.rabbitmq.client.impl.Frame: Computes the AMQP wire-protocol length of an encoded field-array of type Object[]
arraySize(List<?>) - Static method in class com.rabbitmq.client.impl.Frame: Computes the AMQP 0-9-1 wire-protocol length of an encoded field-array of type List
asLongString(byte[]) - Static method in class com.rabbitmq.client.impl.LongStringHelper: Converts a binary block to a LongString.
asLongString(String) - Static method in class com.rabbitmq.client.impl.LongStringHelper: Converts a String to a LongString using UTF-8 encoding.
asyncCompletableRpc(Method) - Method in interface com.rabbitmq.client.Channel: Asynchronously send a method over this channel.
asyncCompletableRpc(Method) - Method in class com.rabbitmq.client.impl.ChannelN
asyncCompletableRpc(Method) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
asyncRpc(Method) - Method in interface com.rabbitmq.client.Channel: Asynchronously send a method over this channel.
asyncRpc(Method) - Method in class com.rabbitmq.client.impl.ChannelN
asyncRpc(Method) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
asyncRpc(Method, CompletableFuture<Command>) - Method in class com.rabbitmq.client.impl.AMQChannel
AuthenticationFailureException - Exception in com.rabbitmq.client: Thrown when the broker refuses access due to an authentication failure.
AuthenticationFailureException(String) - Constructor for exception com.rabbitmq.client.AuthenticationFailureException
autoAck(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
autoDelete() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
autoDelete() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
autoDelete(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
autoDelete(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
autoDelete(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
autoDelete(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
automaticallyRecover(AutorecoveringConnection, Connection) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
AutorecoveringChannel - Class in com.rabbitmq.client.impl.recovery: Channel implementation that is automatically recovered during connection recovery.
AutorecoveringChannel(AutorecoveringConnection, RecoveryAwareChannelN) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
AutorecoveringConnection - Class in com.rabbitmq.client.impl.recovery: Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.
AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, AddressResolver) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, AddressResolver, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, List<Address>) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
available() - Method in class com.rabbitmq.client.impl.TruncatedInputStream

B

backoff(int) - Method in interface com.rabbitmq.client.impl.recovery.BackoffPolicy: Wait depending on the current attempt number (1, 2, 3, etc)
backoffPolicy - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
backoffPolicy - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
backoffPolicy(BackoffPolicy) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
BackoffPolicy - Interface in com.rabbitmq.client.impl.recovery: Backoff policy for topology recovery retry attempts.
Basic() - Constructor for class com.rabbitmq.client.AMQP.Basic
Basic() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic
BASIC - Static variable in class com.rabbitmq.client.MessageProperties: Content-type "application/octet-stream", deliveryMode 1 (nonpersistent), priority zero
basicAck(long, boolean) - Method in interface com.rabbitmq.client.Channel: Acknowledge one or several received messages.
basicAck(long, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Acknowledge one or several received messages.
basicAck(long, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicAck(long, boolean) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
basicAck(Channel, long, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicAck(Channel, long, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
basicAck(Channel, long, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicCancel(Channel, String) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicCancel(Channel, String) - Method in interface com.rabbitmq.client.MetricsCollector
basicCancel(Channel, String) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicCancel(String) - Method in interface com.rabbitmq.client.Channel: Cancel a consumer.
basicCancel(String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Cancel a consumer.
basicCancel(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(Channel, String, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicConsume(Channel, String, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
basicConsume(Channel, String, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicConsume(String, boolean, Consumer) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in interface com.rabbitmq.client.Channel: Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel: Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, Consumer) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, Consumer) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel: Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicGet(String, boolean) - Method in interface com.rabbitmq.client.Channel: Retrieve a message from a queue using AMQP.Basic.Get
basicGet(String, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Retrieve a message from a queue using AMQP.Basic.Get
basicGet(String, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicNack(long, boolean, boolean) - Method in interface com.rabbitmq.client.Channel: Reject one or several received messages.
basicNack(long, boolean, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Reject one or several received messages.
basicNack(long, boolean, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicNack(long, boolean, boolean) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
basicNack(Channel, long) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicNack(Channel, long) - Method in interface com.rabbitmq.client.MetricsCollector
basicNack(Channel, long) - Method in class com.rabbitmq.client.NoOpMetricsCollector
BasicProperties - Interface in com.rabbitmq.client
BasicProperties() - Constructor for class com.rabbitmq.client.AMQP.BasicProperties
BasicProperties(DataInputStream) - Constructor for class com.rabbitmq.client.AMQP.BasicProperties
BasicProperties(String, String, Map<String, Object>, Integer, Integer, String, String, String, String, Date, String, String, String, String) - Constructor for class com.rabbitmq.client.AMQP.BasicProperties
basicPublish(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicPublish(Channel) - Method in interface com.rabbitmq.client.MetricsCollector
basicPublish(Channel) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Channel: Publish a message.
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Publish a message.
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Channel: Publish a message.
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Publish a message.
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Channel: Publish a message.
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Publish a message.
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicPublishAck(Channel, long, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicPublishAck(Channel, long, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
basicPublishAck(Channel, long, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicPublishFailure(Channel, Throwable) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicPublishFailure(Channel, Throwable) - Method in interface com.rabbitmq.client.MetricsCollector
basicPublishFailure(Channel, Throwable) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicPublishNack(Channel, long, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicPublishNack(Channel, long, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
basicPublishNack(Channel, long, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicPublishUnrouted(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicPublishUnrouted(Channel) - Method in interface com.rabbitmq.client.MetricsCollector
basicPublishUnrouted(Channel) - Method in class com.rabbitmq.client.NoOpMetricsCollector
basicQos(int) - Method in interface com.rabbitmq.client.Channel: Request a specific prefetchCount "quality of service" settings for this channel.
basicQos(int) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Request a specific prefetchCount "quality of service" settings for this channel.
basicQos(int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicQos(int, boolean) - Method in interface com.rabbitmq.client.Channel: Request a specific prefetchCount "quality of service" settings for this channel.
basicQos(int, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Request a specific prefetchCount "quality of service" settings for this channel.
basicQos(int, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicQos(int, int, boolean) - Method in interface com.rabbitmq.client.Channel: Request specific "quality of service" settings.
basicQos(int, int, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Request specific "quality of service" settings.
basicQos(int, int, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicRecover() - Method in interface com.rabbitmq.client.Channel: Ask the broker to resend unacknowledged messages.
basicRecover() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Ask the broker to resend unacknowledged messages.
basicRecover() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicRecover(boolean) - Method in interface com.rabbitmq.client.Channel: Ask the broker to resend unacknowledged messages.
basicRecover(boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Ask the broker to resend unacknowledged messages.
basicRecover(boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicReject(long, boolean) - Method in interface com.rabbitmq.client.Channel: Reject a message.
basicReject(long, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Reject a message.
basicReject(long, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
basicReject(long, boolean) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
basicReject(Channel, long) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
basicReject(Channel, long) - Method in interface com.rabbitmq.client.MetricsCollector
basicReject(Channel, long) - Method in class com.rabbitmq.client.NoOpMetricsCollector
Bind(int, String, String, String, boolean, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
Bind(int, String, String, String, boolean, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
Bind(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
Bind(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
binding() - Method in class com.rabbitmq.client.impl.recovery.RetryContext: The to-be-recovered entity as a binding.
bindingRecoveryRetryCondition - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
bindingRecoveryRetryCondition - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
bindingRecoveryRetryCondition(BiPredicate<? super RecordedBinding, Exception>) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
bindingRecoveryRetryOperation - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
bindingRecoveryRetryOperation - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
bindingRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?>) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
BindOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
BindOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
BindOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
BindOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
Blocked(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
Blocked(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
BlockedCallback - Interface in com.rabbitmq.client: Implement this interface in order to be notified of connection block events.
BlockedListener - Interface in com.rabbitmq.client: Implement this interface in order to be notified of connection block and unblock events.
BlockingCell<T> - Class in com.rabbitmq.utility: Simple one-shot IPC mechanism.
BlockingCell() - Constructor for class com.rabbitmq.utility.BlockingCell: Instantiate a new BlockingCell waiting for a value of the specified type.
BlockingQueueNioQueue - Class in com.rabbitmq.client.impl.nio: Bridge between NioQueue and JDK's BlockingQueue.
BlockingQueueNioQueue(BlockingQueue<WriteRequest>, int) - Constructor for class com.rabbitmq.client.impl.nio.BlockingQueueNioQueue
BlockingRpcContinuation() - Constructor for class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
BlockingRpcContinuation(Method) - Constructor for class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
BlockingValueOrException<V,E extends Throwable & SensibleClone<E>> - Class in com.rabbitmq.utility
BlockingValueOrException() - Constructor for class com.rabbitmq.utility.BlockingValueOrException
body - Variable in class com.rabbitmq.client.RpcClient.Response
build() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
build() - Method in class com.rabbitmq.client.AMQP.Access.RequestOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Cancel.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.CancelOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.ConsumeOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Get.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.GetEmpty.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.QosOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Recover.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.RecoverAsync.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.RecoverOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Reject.Builder
build() - Method in class com.rabbitmq.client.AMQP.Basic.Return.Builder
build() - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
build() - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
build() - Method in class com.rabbitmq.client.AMQP.Channel.CloseOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Channel.Flow.Builder
build() - Method in class com.rabbitmq.client.AMQP.Channel.FlowOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Channel.Open.Builder
build() - Method in class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Confirm.Select.Builder
build() - Method in class com.rabbitmq.client.AMQP.Confirm.SelectOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Blocked.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.CloseOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Open.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.OpenOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Secure.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.SecureOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.Unblocked.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.UpdateSecret.Builder
build() - Method in class com.rabbitmq.client.AMQP.Connection.UpdateSecretOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.BindOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.DeclareOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.DeleteOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
build() - Method in class com.rabbitmq.client.AMQP.Exchange.UnbindOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.BindOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.DeleteOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.Purge.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.PurgeOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
build() - Method in class com.rabbitmq.client.AMQP.Queue.UnbindOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Tx.Commit.Builder
build() - Method in class com.rabbitmq.client.AMQP.Tx.CommitOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Tx.Rollback.Builder
build() - Method in class com.rabbitmq.client.AMQP.Tx.RollbackOk.Builder
build() - Method in class com.rabbitmq.client.AMQP.Tx.Select.Builder
build() - Method in class com.rabbitmq.client.AMQP.Tx.SelectOk.Builder
build() - Method in class com.rabbitmq.client.impl.DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder: Create the DefaultCredentialsRefreshService instance.
build() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder: Create the OAuth2ClientCredentialsGrantCredentialsProvider instance.
build() - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
build() - Method in class com.rabbitmq.client.SocketChannelConfigurators.Builder: Return the configured SocketConfigurator.
build() - Method in class com.rabbitmq.client.SocketConfigurators.Builder: Return the configured SocketConfigurator.
build() - Method in class com.rabbitmq.client.SslEngineConfigurators.Builder: Return the configured SslEngineConfigurator.
builder() - Method in class com.rabbitmq.client.AMQP.BasicProperties
builder() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration: Go back to the builder to configure non-TLS settings.
builder() - Static method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
builder() - Static method in class com.rabbitmq.client.SocketChannelConfigurators: Builder to configure and creates a SocketChannelConfigurator instance.
builder() - Static method in class com.rabbitmq.client.SocketConfigurators: Builder to configure and creates a SocketConfigurator instance.
builder() - Static method in class com.rabbitmq.client.SslEngineConfigurators: Builder to configure and creates a SslEngineConfigurator instance.
Builder() - Constructor for class com.rabbitmq.client.AMQP.Access.Request.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Access.RequestOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Ack.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Cancel.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.CancelOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Consume.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.ConsumeOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Get.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.GetEmpty.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Nack.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Publish.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Qos.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.QosOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Recover.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.RecoverAsync.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.RecoverOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Reject.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Basic.Return.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.BasicProperties.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Channel.Close.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Channel.CloseOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Channel.Flow.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Channel.FlowOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Channel.Open.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Confirm.Select.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Confirm.SelectOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Blocked.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Close.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.CloseOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Open.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.OpenOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Secure.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.SecureOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Start.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Tune.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.Unblocked.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.UpdateSecret.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Connection.UpdateSecretOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.BindOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.DeclareOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.DeleteOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Exchange.UnbindOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.Bind.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.BindOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.Declare.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.Delete.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.DeleteOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.Purge.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.PurgeOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Queue.UnbindOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Tx.Commit.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Tx.CommitOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Tx.Rollback.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Tx.RollbackOk.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Tx.Select.Builder
Builder() - Constructor for class com.rabbitmq.client.AMQP.Tx.SelectOk.Builder
Builder() - Constructor for class com.rabbitmq.client.SocketChannelConfigurators.Builder
Builder() - Constructor for class com.rabbitmq.client.SocketConfigurators.Builder
Builder() - Constructor for class com.rabbitmq.client.SslEngineConfigurators.Builder
BuiltinExchangeType - Enum in com.rabbitmq.client: Enum for built-in exchange types.
ByteBufferFactory - Interface in com.rabbitmq.client.impl.nio: Contract to create ByteBuffers.
ByteBufferOutputStream - Class in com.rabbitmq.client.impl.nio: Bridge between the byte buffer and stream worlds.
ByteBufferOutputStream(WritableByteChannel, ByteBuffer) - Constructor for class com.rabbitmq.client.impl.nio.ByteBufferOutputStream

C

call(RetryContext) - Method in interface com.rabbitmq.client.impl.recovery.DefaultRetryHandler.RetryOperation
call(String[]) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Deprecated.
This method will be removed in the next major version
call(String, Object[]) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Public API - builds, encodes and sends a JSON-RPC request, and waits for the response.
Cancel(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
Cancel(String, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
CancelCallback - Interface in com.rabbitmq.client: Callback interface to be notified of the cancellation of a consumer.
CancelOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
CancelOk(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
canHandleReply(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
canHandleReply(AMQCommand) - Method in interface com.rabbitmq.client.impl.AMQChannel.RpcContinuation
canHandleReply(AMQCommand) - Method in class com.rabbitmq.client.impl.CompletableFutureRpcWrapper
canHandleReply(AMQCommand) - Method in class com.rabbitmq.client.impl.RpcContinuationRpcWrapper
canHandleReply(AMQCommand) - Method in interface com.rabbitmq.client.impl.RpcWrapper
capabilities(String) - Method in class com.rabbitmq.client.AMQP.Connection.Open.Builder
challenge(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.Secure.Builder
challenge(String) - Method in class com.rabbitmq.client.AMQP.Connection.Secure.Builder
channel - Variable in class com.rabbitmq.client.impl.Frame: Frame channel number, 0-65535
channel - Variable in class com.rabbitmq.client.impl.nio.FrameBuilder
channel - Variable in class com.rabbitmq.client.impl.recovery.RecordedEntity
channel(Channel) - Method in class com.rabbitmq.client.RpcClientParams
Channel - Interface in com.rabbitmq.client: Interface to a channel.
Channel() - Constructor for class com.rabbitmq.client.AMQP.Channel
Channel() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel
CHANNEL_CLOSED_NOT_FOUND - Static variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryLogic: Channel has been closed because of a resource that doesn't exist.
CHANNEL_ERROR - Static variable in interface com.rabbitmq.client.AMQP
CHANNEL_RPC_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CHANNEL_SHOULD_CHECK_RPC_RESPONSE_TYPE - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CHANNEL_SHUTDOWN_TIMEOUT_MULTIPLIER - Static variable in class com.rabbitmq.client.impl.AMQConnection
ChannelContinuationTimeoutException - Exception in com.rabbitmq.client: Exception thrown when a channel times out on a continuation during a RPC call.
ChannelContinuationTimeoutException(TimeoutException, Object, int, Method) - Constructor for exception com.rabbitmq.client.ChannelContinuationTimeoutException
channelId(LongString) - Method in class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
channelId(String) - Method in class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
ChannelManager - Class in com.rabbitmq.client.impl: Manages a set of channels, indexed by channel number (1.._channelMax).
ChannelManager(ConsumerWorkService, int) - Constructor for class com.rabbitmq.client.impl.ChannelManager
ChannelManager(ConsumerWorkService, int, ThreadFactory) - Constructor for class com.rabbitmq.client.impl.ChannelManager
ChannelManager(ConsumerWorkService, int, ThreadFactory, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.ChannelManager
channelMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
channelMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
ChannelN - Class in com.rabbitmq.client.impl: Main interface to AMQP protocol functionality.
ChannelN(AMQConnection, int, ConsumerWorkService) - Constructor for class com.rabbitmq.client.impl.ChannelN: Construct a new channel on the given connection with the given channel number.
ChannelN(AMQConnection, int, ConsumerWorkService, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.ChannelN: Construct a new channel on the given connection with the given channel number.
CHANNELS - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
channelShouldCheckRpcResponseType() - Method in class com.rabbitmq.client.impl.ConnectionParams
checkClientTrusted(X509Certificate[], String) - Method in class com.rabbitmq.client.TrustEverythingTrustManager: Doesn't even bother looking at its arguments, simply returns, which makes the check succeed.
checkConsumer() - Method in class com.rabbitmq.client.RpcClient: Private API - ensures the RpcClient is correctly open.
checkContentType(String) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
checkPreconditions() - Static method in class com.rabbitmq.client.impl.AMQCommand: Called to check internal code assumptions.
checkResponseCode(int) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
checkServerTrusted(X509Certificate[], String) - Method in class com.rabbitmq.client.TrustEverythingTrustManager: Doesn't even bother looking at its arguments, simply returns, which makes the check succeed.
checkVersion(Version, Version) - Static method in class com.rabbitmq.client.impl.Version: Check compatibility of a client and server version, from the client's perspective.
classId - Variable in exception com.rabbitmq.client.UnknownClassOrMethodId
classId(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
classId(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
cleanStaleState() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Clean inner state for close connections and channels.
cleanUp() - Method in class com.rabbitmq.client.impl.nio.NioLoopContext
clear() - Method in class com.rabbitmq.client.impl.SetQueue: Remove all items from the queue.
clear() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
clearBlockedListeners() - Method in interface com.rabbitmq.client.Connection: Remove all BlockedListeners.
clearBlockedListeners() - Method in class com.rabbitmq.client.impl.AMQConnection
clearBlockedListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
clearConfirmListeners() - Method in interface com.rabbitmq.client.Channel: Remove all ConfirmListeners.
clearConfirmListeners() - Method in class com.rabbitmq.client.impl.ChannelN
clearConfirmListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
clearReturnListeners() - Method in interface com.rabbitmq.client.Channel: Remove all ReturnListeners.
clearReturnListeners() - Method in class com.rabbitmq.client.impl.ChannelN
clearReturnListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
CLIENT_PROPERTIES_PREFIX - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
clientId(String) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder: Set the OAuth 2 client ID
clientProperties(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
clientSecret(String) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder: Set the secret (password) to use to get a token.
ClientVersion - Class in com.rabbitmq.client.impl: Publicly available Client Version information
ClientVersion() - Constructor for class com.rabbitmq.client.impl.ClientVersion
clone() - Method in class com.rabbitmq.client.ConnectionFactory
clone() - Method in class com.rabbitmq.client.impl.AMQBasicProperties
clone() - Method in class com.rabbitmq.client.impl.AMQContentHeader
close() - Method in interface com.rabbitmq.client.Channel: Close this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close() - Method in interface com.rabbitmq.client.Connection: Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close() - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Close this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close() - Method in class com.rabbitmq.client.impl.DefaultCredentialsRefreshService
close() - Method in interface com.rabbitmq.client.impl.FrameHandler: Close the underlying data connection (complaint not permitted).
close() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
close() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
close() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
close() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
close() - Method in class com.rabbitmq.client.RpcClient: Public API - cancels the consumer, thus deleting the temporary queue, and marks the RpcClient as closed.
close() - Method in class com.rabbitmq.client.RpcServer: Public API - cancels the consumer, thus deleting the queue, if it was a temporary queue, and marks the RpcServer as closed.
close(int) - Method in interface com.rabbitmq.client.Connection: Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close(int) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close(int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
close(int, String) - Method in interface com.rabbitmq.client.Channel: Close this channel.
close(int, String) - Method in interface com.rabbitmq.client.Connection: Close this connection and all its channels.
close(int, String) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Close this connection and all its channels.
close(int, String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Close this channel.
close(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
close(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
close(int, String, boolean, Throwable) - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - Delegates to the six-argument close method, passing -1 for the timeout, and false for the abort flag.
close(int, String, boolean, Throwable, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Protected API - Close channel with code and message, indicating the source of the closure and a causing exception (null if none).
close(int, String, boolean, Throwable, int, boolean) - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - Close this connection with the given code, message, source and timeout value for all the close operations to complete.
close(int, String, int) - Method in interface com.rabbitmq.client.Connection: Close this connection and all its channels.
close(int, String, int) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Close this connection and all its channels.
close(int, String, int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
close(WritableByteChannel, SSLEngine) - Static method in class com.rabbitmq.client.impl.nio.SslEngineHelper
Close(int, String, int, int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Close
Close(int, String, int, int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Close
Close(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Close
Close(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Close
closeChannel(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
closeChannel(Channel) - Method in interface com.rabbitmq.client.MetricsCollector
closeChannel(Channel) - Method in class com.rabbitmq.client.NoOpMetricsCollector
closeConnection(Connection) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
closeConnection(Connection) - Method in interface com.rabbitmq.client.MetricsCollector
closeConnection(Connection) - Method in class com.rabbitmq.client.NoOpMetricsCollector
CloseOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
CloseOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
CloseOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
CloseOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
clusterId(String) - Method in class com.rabbitmq.client.AMQP.Basic.GetEmpty.Builder
clusterId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
coerce(String, String) - Static method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Deprecated.
This method will be removed in the next major version
com.rabbitmq.client - package com.rabbitmq.client: The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.
com.rabbitmq.client.impl - package com.rabbitmq.client.impl: Implementations of interfaces specified in the client API, and their supporting classes.
com.rabbitmq.client.impl.nio - package com.rabbitmq.client.impl.nio: NIO network connector.
com.rabbitmq.client.impl.recovery - package com.rabbitmq.client.impl.recovery: Implementation of connection and topology recovery.
com.rabbitmq.tools - package com.rabbitmq.tools: Non-core utilities and administration tools.
com.rabbitmq.tools.json - package com.rabbitmq.tools.json: JSON reader/writer and utility classes.
com.rabbitmq.tools.jsonrpc - package com.rabbitmq.tools.jsonrpc: JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.
com.rabbitmq.utility - package com.rabbitmq.utility: Utility package of helper classes, mostly used in the implementation code.
Command - Interface in com.rabbitmq.client: Interface to a container for an AMQP method-and-arguments, with optional content header and body.
COMMAND_INVALID - Static variable in interface com.rabbitmq.client.AMQP
Commit() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
Commit(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
CommitOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
CommitOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
compareTo(DnsSrvRecordAddressResolver.SrvRecord) - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
CompletableFutureRpcWrapper - Class in com.rabbitmq.client.impl
CompletableFutureRpcWrapper(Method, CompletableFuture<Command>) - Constructor for class com.rabbitmq.client.impl.CompletableFutureRpcWrapper
complete(AMQCommand) - Method in class com.rabbitmq.client.impl.CompletableFutureRpcWrapper
complete(AMQCommand) - Method in class com.rabbitmq.client.impl.RpcContinuationRpcWrapper
complete(AMQCommand) - Method in interface com.rabbitmq.client.impl.RpcWrapper
computeDefaultTlsProtocol(String[]) - Static method in class com.rabbitmq.client.ConnectionFactory
configurator - Variable in class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
configure(Socket) - Method in class com.rabbitmq.client.DefaultSocketConfigurator: Provides a hook to insert custom configuration of the sockets used to connect to an AMQP server before they connect.
configure(Socket) - Method in interface com.rabbitmq.client.SocketConfigurator: Provides a hook to insert custom configuration of the sockets used to connect to an AMQP server before they connect.
configure(SocketChannel) - Method in class com.rabbitmq.client.DefaultSocketChannelConfigurator: Provides a hook to insert custom configuration of the SocketChannels used to connect to an AMQP server before they connect.
configure(SocketChannel) - Method in interface com.rabbitmq.client.SocketChannelConfigurator: Provides a hook to insert custom configuration of the SocketChannels used to connect to an AMQP server before they connect.
configure(SSLEngine) - Method in interface com.rabbitmq.client.SslEngineConfigurator: Provides a hook to insert custom configuration of the SSLEngines used to connect to an AMQP server before they connect.
configureChannelManager(ChannelManager) - Method in class com.rabbitmq.client.impl.AMQConnection
configureConnection(HttpURLConnection) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
configureConnectionForHttps(HttpURLConnection) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
Confirm() - Constructor for class com.rabbitmq.client.AMQP.Confirm
Confirm() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Confirm
ConfirmCallback - Interface in com.rabbitmq.client: Implement this interface in order to be notified of Confirm events.
ConfirmListener - Interface in com.rabbitmq.client: Implement this interface in order to be notified of Confirm events.
confirmSelect() - Method in interface com.rabbitmq.client.Channel: Enables publisher acknowledgements on this channel.
confirmSelect() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Enables publisher acknowledgements on this channel.
confirmSelect() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
connection() - Method in class com.rabbitmq.client.impl.recovery.RetryContext: The underlying connection.
Connection - Interface in com.rabbitmq.client: Public API: Interface to an AMQ connection.
Connection() - Constructor for class com.rabbitmq.client.AMQP.Connection
Connection() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection
CONNECTION_CHANNEL_MAX - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CONNECTION_FORCED - Static variable in interface com.rabbitmq.client.AMQP
CONNECTION_FRAME_MAX - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CONNECTION_HEARTBEAT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CONNECTION_RECOVERY_ENABLED - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CONNECTION_RECOVERY_INTERVAL - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
CONNECTION_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
connectionConfigurator(Consumer<HttpURLConnection>) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder: A hook to configure the HttpURLConnection before the request is sent.
ConnectionFactory - Class in com.rabbitmq.client: Convenience factory class to facilitate opening a Connection to a RabbitMQ node.
ConnectionFactory() - Constructor for class com.rabbitmq.client.ConnectionFactory
ConnectionFactoryConfigurator - Class in com.rabbitmq.client: Helper class to load ConnectionFactory settings from a property file.
ConnectionFactoryConfigurator() - Constructor for class com.rabbitmq.client.ConnectionFactoryConfigurator
ConnectionParams - Class in com.rabbitmq.client.impl
ConnectionParams() - Constructor for class com.rabbitmq.client.impl.ConnectionParams
CONNECTIONS - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
connectionTimeout - Variable in class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
Consume(int, String, String, boolean, boolean, boolean, boolean, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
Consume(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
CONSUMED_MESSAGES - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
consumedMessage(Channel, long, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
consumedMessage(Channel, long, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
consumedMessage(Channel, long, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
consumedMessage(Channel, long, String) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
consumedMessage(Channel, long, String) - Method in interface com.rabbitmq.client.MetricsCollector
consumedMessage(Channel, long, String) - Method in class com.rabbitmq.client.NoOpMetricsCollector
ConsumeOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
ConsumeOk(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
consumer() - Method in class com.rabbitmq.client.impl.recovery.RetryContext: The to-be-recovered entity as a consumer.
consumer(Consumer) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
Consumer - Interface in com.rabbitmq.client: Interface for application callback objects to receive notifications and messages from a queue by subscription.
ConsumerCancelledException - Exception in com.rabbitmq.client
ConsumerCancelledException() - Constructor for exception com.rabbitmq.client.ConsumerCancelledException
consumerCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
consumerCount(String) - Method in interface com.rabbitmq.client.Channel: Returns the number of consumers on a queue.
consumerCount(String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Returns the number of consumers on a queue.
consumerCount(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
consumerRecovered(String, String) - Method in interface com.rabbitmq.client.impl.recovery.ConsumerRecoveryListener
ConsumerRecoveryListener - Interface in com.rabbitmq.client.impl.recovery: Not part of the public API.
consumerRecoveryRetryCondition - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
consumerRecoveryRetryCondition - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
consumerRecoveryRetryCondition(BiPredicate<? super RecordedConsumer, Exception>) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
consumerRecoveryRetryOperation - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
consumerRecoveryRetryOperation - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
consumerRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?>) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
ConsumerShutdownSignalCallback - Interface in com.rabbitmq.client: Callback interface to be notified when either the consumer channel or the underlying connection has been shut down.
consumerTag - Variable in class com.rabbitmq.client.RpcClient.Response
consumerTag(String) - Method in class com.rabbitmq.client.AMQP.Basic.Cancel.Builder
consumerTag(String) - Method in class com.rabbitmq.client.AMQP.Basic.CancelOk.Builder
consumerTag(String) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
consumerTag(String) - Method in class com.rabbitmq.client.AMQP.Basic.ConsumeOk.Builder
consumerTag(String) - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
consumerTag(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
ConsumerWorkService - Class in com.rabbitmq.client.impl
ConsumerWorkService(ExecutorService, ThreadFactory, int) - Constructor for class com.rabbitmq.client.impl.ConsumerWorkService
ConsumerWorkService(ExecutorService, ThreadFactory, int, int) - Constructor for class com.rabbitmq.client.impl.ConsumerWorkService
contains(T) - Method in class com.rabbitmq.client.impl.SetQueue
CONTENT_TOO_LARGE - Static variable in interface com.rabbitmq.client.AMQP
contentEncoding(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
ContentHeader - Interface in com.rabbitmq.client: Public API for abstract AMQP content header objects.
ContentHeaderPropertyReader - Class in com.rabbitmq.client.impl: Parses an AMQP wire-protocol ContentHeader from a DataInputStream.
ContentHeaderPropertyReader(DataInputStream) - Constructor for class com.rabbitmq.client.impl.ContentHeaderPropertyReader: Protected API - Constructs a reader from the given input stream
ContentHeaderPropertyWriter - Class in com.rabbitmq.client.impl: Generates an AMQP wire-protocol packet from a ContentHeader.
ContentHeaderPropertyWriter(DataOutputStream) - Constructor for class com.rabbitmq.client.impl.ContentHeaderPropertyWriter: Constructs a fresh ContentHeaderPropertyWriter.
contentType(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
convert(TreeNode, Class<?>) - Method in class com.rabbitmq.tools.jsonrpc.JacksonJsonRpcMapper
copy(List<E>) - Static method in class com.rabbitmq.utility.Utility: Synchronizes on the list and then returns a copy of the list that is safe to iterate over.
copy(Map<K, V>) - Static method in class com.rabbitmq.utility.Utility: Synchronizes on the map and then returns a copy of the map that is safe to iterate over.
copy(Set<E>) - Static method in class com.rabbitmq.utility.Utility: Synchronizes on the set and then returns a copy of the set that is safe to iterate over.
correlationId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
correlationIdSupplier(Supplier<String>) - Method in class com.rabbitmq.client.RpcClientParams: Logic to generate correlation IDs.
CRDemoMechanism - Class in com.rabbitmq.client.impl: Provides equivalent security to PLAIN but demos use of Connection.Secure(Ok) START-OK: Username SECURE: "Please tell me your password" SECURE-OK: Password
CRDemoMechanism() - Constructor for class com.rabbitmq.client.impl.CRDemoMechanism
CRDemoMechanism.CRDemoSaslConfig - Class in com.rabbitmq.client.impl
CRDemoSaslConfig() - Constructor for class com.rabbitmq.client.impl.CRDemoMechanism.CRDemoSaslConfig
create(Address, String) - Method in interface com.rabbitmq.client.impl.FrameHandlerFactory
create(Address, String) - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerFactory
create(Address, String) - Method in class com.rabbitmq.client.impl.SocketFrameHandlerFactory
create(String) - Method in interface com.rabbitmq.client.SslContextFactory: Create a SSLContext for a given name.
create(Socket) - Method in class com.rabbitmq.client.impl.SocketFrameHandlerFactory
createAddressResolver(List<Address>) - Method in class com.rabbitmq.client.ConnectionFactory
createChannel() - Method in interface com.rabbitmq.client.Connection: Create a new channel, using an internally allocated channel number.
createChannel() - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Create a new channel, using an internally allocated channel number.
createChannel() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
createChannel(int) - Method in interface com.rabbitmq.client.Connection: Create a new channel, using the specified channel number if possible.
createChannel(int) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Create a new channel, using the specified channel number if possible.
createChannel(int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
createChannel(AMQConnection) - Method in class com.rabbitmq.client.impl.ChannelManager
createChannel(AMQConnection, int) - Method in class com.rabbitmq.client.impl.ChannelManager
createConnection(ConnectionParams, FrameHandler, MetricsCollector) - Method in class com.rabbitmq.client.ConnectionFactory
createConnection(ConnectionParams, FrameHandler, MetricsCollector) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
createEncryptedByteBuffer(NioContext) - Method in class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
createEncryptedReadBuffer(NioContext) - Method in interface com.rabbitmq.client.impl.nio.ByteBufferFactory: Create the network read ByteBuffer.
createEncryptedReadBuffer(NioContext) - Method in class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
createEncryptedWriteBuffer(NioContext) - Method in interface com.rabbitmq.client.impl.nio.ByteBufferFactory: Create the network write ByteBuffer.
createEncryptedWriteBuffer(NioContext) - Method in class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
createFrameHandlerFactory() - Method in class com.rabbitmq.client.ConnectionFactory
createProxy(Class<T>) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Public API - gets a dynamic proxy for a particular interface class.
createReadBuffer(NioContext) - Method in interface com.rabbitmq.client.impl.nio.ByteBufferFactory: Create the ByteBuffer that contains inbound frames.
createReadBuffer(NioContext) - Method in class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
createSocket(String) - Method in class com.rabbitmq.client.impl.SocketFrameHandlerFactory
createWriteBuffer(NioContext) - Method in interface com.rabbitmq.client.impl.nio.ByteBufferFactory: Create the ByteBuffer that contains outbound frames.
createWriteBuffer(NioContext) - Method in class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
CredentialsProvider - Interface in com.rabbitmq.client.impl: Provider interface for establishing credentials for connecting to the broker.
CredentialsRefreshService - Interface in com.rabbitmq.client.impl: Provider interface to refresh credentials when appropriate and perform an operation once the credentials have been renewed.

D

Declare(int, String, boolean, boolean, boolean, boolean, boolean, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
Declare(int, String, String, boolean, boolean, boolean, boolean, boolean, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
Declare(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
Declare(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
DeclareOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
DeclareOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
DeclareOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
DeclareOk(String, int, int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
decode(byte[]) - Static method in class com.rabbitmq.client.MapRpcServer
decrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Decrements channel count.
decrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
decrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
decrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
decrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Decrements connection count.
decrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
decrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
decrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
DEFAULT - Static variable in class com.rabbitmq.client.SocketChannelConfigurators: Default SocketChannelConfigurator that disables Nagle's algorithm.
DEFAULT - Static variable in class com.rabbitmq.client.SocketConfigurators: Default SocketConfigurator that disables Nagle's algorithm.
DEFAULT - Static variable in class com.rabbitmq.client.SslEngineConfigurators: Default SslEngineConfigurator, does nothing.
DEFAULT_AMQP_OVER_SSL_PORT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default ssl port
DEFAULT_AMQP_PORT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default non-ssl port
DEFAULT_CHANNEL_MAX - Static variable in class com.rabbitmq.client.ConnectionFactory: Default maximum channel number; 2047 because it's 2048 on the server side minus channel 0, which each connection uses for negotiation and error communication
DEFAULT_CHANNEL_RPC_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default continuation timeout for RPC calls in channels: 10 minutes
DEFAULT_CONNECTION_RECOVERY_TRIGGERING_CONDITION - Static variable in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
DEFAULT_CONNECTION_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default TCP connection timeout: 60 seconds
DEFAULT_FRAME_MAX - Static variable in class com.rabbitmq.client.ConnectionFactory: Default maximum frame size; zero means no limit
DEFAULT_HANDSHAKE_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default AMQP 0-9-1 connection handshake timeout.
DEFAULT_HEARTBEAT - Static variable in class com.rabbitmq.client.ConnectionFactory: Default heart-beat interval; 60 seconds
DEFAULT_HOST - Static variable in class com.rabbitmq.client.ConnectionFactory: The default host
DEFAULT_NETWORK_RECOVERY_INTERVAL - Static variable in class com.rabbitmq.client.ConnectionFactory: The default network recovery interval: 5000 millis
DEFAULT_PASS - Static variable in class com.rabbitmq.client.ConnectionFactory: Default password
DEFAULT_PREFIX - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
DEFAULT_REPLY_HANDLER - Static variable in class com.rabbitmq.client.RpcClient
DEFAULT_SHUTDOWN_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default shutdown timeout; zero means wait indefinitely
DEFAULT_USER - Static variable in class com.rabbitmq.client.ConnectionFactory: Default user name
DEFAULT_VHOST - Static variable in class com.rabbitmq.client.ConnectionFactory: Default virtual host
DEFAULT_WORK_POOL_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactory: The default timeout for work pool enqueueing: no timeout
DefaultByteBufferFactory - Class in com.rabbitmq.client.impl.nio: Default ByteBufferFactory that creates heap-based ByteBuffers.
DefaultByteBufferFactory() - Constructor for class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
DefaultByteBufferFactory(Function<Integer, ByteBuffer>) - Constructor for class com.rabbitmq.client.impl.nio.DefaultByteBufferFactory
defaultClientProperties() - Static method in class com.rabbitmq.client.impl.AMQConnection: Retrieve a copy of the default table of client properties that will be sent to the server during connection startup.
defaultConfigurator() - Method in class com.rabbitmq.client.SocketChannelConfigurators.Builder: Set default configuration.
defaultConfigurator() - Static method in class com.rabbitmq.client.SocketChannelConfigurators: The default SocketChannelConfigurator that disables Nagle's algorithm.
defaultConfigurator() - Method in class com.rabbitmq.client.SocketConfigurators.Builder: Set default configuration.
defaultConfigurator() - Static method in class com.rabbitmq.client.SocketConfigurators: The default SocketConfigurator that disables Nagle's algorithm.
defaultConfigurator() - Method in class com.rabbitmq.client.SslEngineConfigurators.Builder: Set default configuration (no op).
defaultConfigurator() - Static method in class com.rabbitmq.client.SslEngineConfigurators: Default SslEngineConfigurator, does nothing.
DefaultConsumer - Class in com.rabbitmq.client: Convenience class providing a default implementation of Consumer.
DefaultConsumer(Channel) - Constructor for class com.rabbitmq.client.DefaultConsumer: Constructs a new instance and records its association to the passed-in channel.
DefaultCredentialsProvider - Class in com.rabbitmq.client.impl: Default implementation of a CredentialsProvider which simply holds a static username and password.
DefaultCredentialsProvider(String, String) - Constructor for class com.rabbitmq.client.impl.DefaultCredentialsProvider
DefaultCredentialsRefreshService - Class in com.rabbitmq.client.impl: Scheduling-based implementation of CredentialsRefreshService.
DefaultCredentialsRefreshService(ScheduledExecutorService, Function<Duration, Duration>, Function<Duration, Boolean>) - Constructor for class com.rabbitmq.client.impl.DefaultCredentialsRefreshService: Constructor.
DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder - Class in com.rabbitmq.client.impl: Builder to create instances of DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder.
DefaultCredentialsRefreshServiceBuilder() - Constructor for class com.rabbitmq.client.impl.DefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder
DefaultExceptionHandler - Class in com.rabbitmq.client.impl: Default implementation of ExceptionHandler used by AMQConnection.
DefaultExceptionHandler() - Constructor for class com.rabbitmq.client.impl.DefaultExceptionHandler
DefaultJsonRpcMapper - Class in com.rabbitmq.tools.jsonrpc: Deprecated.
use JacksonJsonRpcMapper instead
DefaultJsonRpcMapper() - Constructor for class com.rabbitmq.tools.jsonrpc.DefaultJsonRpcMapper: Deprecated.
DefaultMethodVisitor() - Constructor for class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
DefaultRecoveryDelayHandler(long) - Constructor for class com.rabbitmq.client.RecoveryDelayHandler.DefaultRecoveryDelayHandler: Default Constructor
DefaultRetryHandler - Class in com.rabbitmq.client.impl.recovery: Composable topology recovery retry handler.
DefaultRetryHandler(BiPredicate<? super RecordedQueue, Exception>, BiPredicate<? super RecordedExchange, Exception>, BiPredicate<? super RecordedBinding, Exception>, BiPredicate<? super RecordedConsumer, Exception>, DefaultRetryHandler.RetryOperation<?>, DefaultRetryHandler.RetryOperation<?>, DefaultRetryHandler.RetryOperation<?>, DefaultRetryHandler.RetryOperation<?>, int, BackoffPolicy) - Constructor for class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
DefaultRetryHandler.RetryOperation<T> - Interface in com.rabbitmq.client.impl.recovery
DefaultSaslConfig - Class in com.rabbitmq.client: Default SASL configuration.
DefaultSocketChannelConfigurator - Class in com.rabbitmq.client
DefaultSocketChannelConfigurator() - Constructor for class com.rabbitmq.client.DefaultSocketChannelConfigurator
DefaultSocketConfigurator - Class in com.rabbitmq.client
DefaultSocketConfigurator() - Constructor for class com.rabbitmq.client.DefaultSocketConfigurator
Delete(int, String, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
Delete(int, String, boolean, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
Delete(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
Delete(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
DeleteOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
DeleteOk(int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
DeleteOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
DeleteOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
deleteRecordedConsumer(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel: Delete the recorded consumer from this channel and accompanying connection
Deliver(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
Deliver(String, long, boolean, String, String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
DeliverCallback - Interface in com.rabbitmq.client: Callback interface to be notified when a message is delivered.
Delivery - Class in com.rabbitmq.client: Encapsulates an arbitrary message - simple "bean" holder structure.
Delivery(Envelope, AMQP.BasicProperties, byte[]) - Constructor for class com.rabbitmq.client.Delivery
deliveryMode(Integer) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Reject.Builder
destination - Variable in class com.rabbitmq.client.impl.recovery.RecordedBinding
destination(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
destination(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
destination(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
dev() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration: Set up a non-secured environment, useful for development and testing.
DIRECT - Enum constant in enum com.rabbitmq.client.BuiltinExchangeType
DISABLE_NAGLE_ALGORITHM - Static variable in class com.rabbitmq.client.SocketChannelConfigurators: Disable Nagle's algorithm.
DISABLE_NAGLE_ALGORITHM - Static variable in class com.rabbitmq.client.SocketConfigurators: Disable Nagle's algorithm.
disableNagleAlgorithm() - Method in class com.rabbitmq.client.SocketChannelConfigurators.Builder: Disable Nagle's Algorithm.
disableNagleAlgorithm() - Static method in class com.rabbitmq.client.SocketChannelConfigurators: SocketChannelConfigurator that disables Nagle's algorithm.
disableNagleAlgorithm() - Method in class com.rabbitmq.client.SocketConfigurators.Builder: Disable Nagle's Algorithm.
disableNagleAlgorithm() - Static method in class com.rabbitmq.client.SocketConfigurators: SocketConfigurator that disables Nagle's algorithm.
disconnectChannel(ChannelN) - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - respond, in the driver thread, to a ShutdownSignal.
dispatchIoErrorToConnection(SocketChannelFrameHandlerState, Throwable) - Method in class com.rabbitmq.client.impl.nio.NioLoop
dispatchShutdownToConnection(SocketChannelFrameHandlerState) - Method in class com.rabbitmq.client.impl.nio.NioLoop
dispatchShutdownToConnection(Runnable, String) - Method in class com.rabbitmq.client.impl.nio.NioLoop
DnsRecordIpAddressResolver - Class in com.rabbitmq.client: AddressResolver that resolves DNS record IPs.
DnsRecordIpAddressResolver() - Constructor for class com.rabbitmq.client.DnsRecordIpAddressResolver
DnsRecordIpAddressResolver(Address) - Constructor for class com.rabbitmq.client.DnsRecordIpAddressResolver
DnsRecordIpAddressResolver(Address, boolean) - Constructor for class com.rabbitmq.client.DnsRecordIpAddressResolver
DnsRecordIpAddressResolver(String) - Constructor for class com.rabbitmq.client.DnsRecordIpAddressResolver
DnsRecordIpAddressResolver(String, int) - Constructor for class com.rabbitmq.client.DnsRecordIpAddressResolver
DnsRecordIpAddressResolver(String, int, boolean) - Constructor for class com.rabbitmq.client.DnsRecordIpAddressResolver
DnsSrvRecordAddressResolver - Class in com.rabbitmq.client: AddressResolver that resolves addresses against a DNS SRV request.
DnsSrvRecordAddressResolver(String) - Constructor for class com.rabbitmq.client.DnsSrvRecordAddressResolver
DnsSrvRecordAddressResolver(String, String) - Constructor for class com.rabbitmq.client.DnsSrvRecordAddressResolver
DnsSrvRecordAddressResolver.SrvRecord - Class in com.rabbitmq.client
doCall(AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.RpcClient
doCall(AMQP.BasicProperties, byte[], int) - Method in class com.rabbitmq.client.RpcClient
doCall(String) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Runs a single JSON-RPC request.
doFinalShutdown() - Method in class com.rabbitmq.client.impl.AMQConnection: private API
doHandshake(WritableByteChannel, ReadableByteChannel, SSLEngine) - Static method in class com.rabbitmq.client.impl.nio.SslEngineHelper
doRetry(BiPredicate<RecordedEntity, Exception>, DefaultRetryHandler.RetryOperation<?>, RecordedEntity, RetryContext) - Method in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
drain(WritableByteChannel, ByteBuffer) - Static method in class com.rabbitmq.client.impl.nio.ByteBufferOutputStream
drainTo(Collection<? super E>) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
drainTo(Collection<? super E>, int) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
durable() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
durable() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
durable(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
durable(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
durable(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
durable(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue

E

EMPTY_FRAME_SIZE - Static variable in class com.rabbitmq.client.impl.AMQCommand: EMPTY_FRAME_SIZE = 8 = 1 + 2 + 4 + 1 1 byte of frame type 2 bytes of channel number 4 bytes of frame payload length 1 byte of payload trailer FRAME_END byte See AMQCommand.checkEmptyFrameSize(), an assertion checked at startup.
EMPTY_STRING - Static variable in class com.rabbitmq.client.impl.recovery.RecordedQueue
ENABLE_HOSTNAME_VERIFICATION - Static variable in class com.rabbitmq.client.SocketConfigurators: Enable server hostname validation for TLS connections.
ENABLE_HOSTNAME_VERIFICATION - Static variable in class com.rabbitmq.client.SslEngineConfigurators: SslEngineConfigurator that enables server hostname verification.
enableHostnameVerification() - Method in class com.rabbitmq.client.ConnectionFactory: Enable server hostname verification for TLS connections.
enableHostnameVerification() - Method in class com.rabbitmq.client.impl.nio.NioParams: Enable server hostname verification for TLS connections.
enableHostnameVerification() - Method in class com.rabbitmq.client.SocketConfigurators.Builder: Enable server hostname verification for TLS connections.
enableHostnameVerification() - Static method in class com.rabbitmq.client.SocketConfigurators: SocketConfigurator that enable server hostname verification for TLS connections.
enableHostnameVerification() - Method in class com.rabbitmq.client.SslEngineConfigurators.Builder: Enables server hostname verification.
enableHostnameVerification() - Static method in class com.rabbitmq.client.SslEngineConfigurators: SslEngineConfigurator that enables server hostname verification.
enableHostnameVerificationForBlockingIo() - Method in class com.rabbitmq.client.ConnectionFactory
enableHostnameVerificationForNio() - Method in class com.rabbitmq.client.ConnectionFactory
encode(Map<String, Object>) - Static method in class com.rabbitmq.client.MapRpcServer
enqueueAsyncRpc(Method, CompletableFuture<Command>) - Method in class com.rabbitmq.client.impl.AMQChannel
enqueueRpc(AMQChannel.RpcContinuation) - Method in class com.rabbitmq.client.impl.AMQChannel
enqueueRpc(AMQChannel.RpcContinuation) - Method in class com.rabbitmq.client.impl.ChannelN
ensureIsOpen() - Method in class com.rabbitmq.client.impl.AMQChannel
ensureUnsignedShort(int) - Static method in class com.rabbitmq.client.ConnectionFactory
entity() - Method in class com.rabbitmq.client.impl.recovery.RetryContext: The to-be-recovered entity.
envelope - Variable in class com.rabbitmq.client.RpcClient.Response
Envelope - Class in com.rabbitmq.client: Encapsulates a group of parameters used for AMQP's Basic methods
Envelope(long, boolean, String, String) - Constructor for class com.rabbitmq.client.Envelope: Construct an Envelope with the specified construction parameters
Environment - Class in com.rabbitmq.client.impl: Infers information about the execution environment, e.g.
Environment() - Constructor for class com.rabbitmq.client.impl.Environment
equals(Object) - Method in class com.rabbitmq.client.Address
equals(Object) - Method in class com.rabbitmq.client.AMQP.BasicProperties
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
equals(Object) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
equals(Object) - Method in class com.rabbitmq.client.impl.nio.SocketChannelRegistration
equals(Object) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
equals(Object) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
equals(Object) - Method in class com.rabbitmq.client.impl.Version
ErrorOnWriteListener - Interface in com.rabbitmq.client.impl: Listener called when a connection gets an IO error trying to write on the socket.
exception() - Method in class com.rabbitmq.client.impl.recovery.RetryContext: The exception that triggered the retry attempt.
ExceptionHandler - Interface in com.rabbitmq.client: Interface to an exception-handling object.
exchange() - Method in class com.rabbitmq.client.impl.recovery.RetryContext: The to-be-recovered entity as an exchange.
exchange(String) - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Basic.Return.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
exchange(String) - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
exchange(String) - Method in class com.rabbitmq.client.RpcClientParams
Exchange() - Constructor for class com.rabbitmq.client.AMQP.Exchange
Exchange() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange
exchangeBind(String, String, String) - Method in interface com.rabbitmq.client.Channel: Bind an exchange to an exchange, with no extra arguments.
exchangeBind(String, String, String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Bind an exchange to an exchange, with no extra arguments.
exchangeBind(String, String, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeBind(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Bind an exchange to an exchange.
exchangeBind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Bind an exchange to an exchange.
exchangeBind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeBindNoWait(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Like Channel.exchangeBind(String, String, String, java.util.Map) but sets nowait parameter to true and returns void (as there will be no response from the server).
exchangeBindNoWait(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Like Channel.exchangeBind(String, String, String, java.util.Map) but sets nowait parameter to true and returns void (as there will be no response from the server).
exchangeBindNoWait(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, BuiltinExchangeType) - Method in interface com.rabbitmq.client.Channel: Actively declare a non-autodelete, non-durable exchange with no extra arguments
exchangeDeclare(String, BuiltinExchangeType) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Actively declare a non-autodelete, non-durable exchange with no extra arguments
exchangeDeclare(String, BuiltinExchangeType) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, BuiltinExchangeType, boolean) - Method in interface com.rabbitmq.client.Channel: Actively declare a non-autodelete exchange with no extra arguments
exchangeDeclare(String, BuiltinExchangeType, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Actively declare a non-autodelete exchange with no extra arguments
exchangeDeclare(String, BuiltinExchangeType, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Declare an exchange, via an interface that allows the complete set of arguments.
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Declare an exchange, via an interface that allows the complete set of arguments.
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Declare an exchange.
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Declare an exchange.
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, String) - Method in interface com.rabbitmq.client.Channel: Actively declare a non-autodelete, non-durable exchange with no extra arguments
exchangeDeclare(String, String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Actively declare a non-autodelete, non-durable exchange with no extra arguments
exchangeDeclare(String, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, String, boolean) - Method in interface com.rabbitmq.client.Channel: Actively declare a non-autodelete exchange with no extra arguments
exchangeDeclare(String, String, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Actively declare a non-autodelete exchange with no extra arguments
exchangeDeclare(String, String, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Declare an exchange, via an interface that allows the complete set of arguments.
exchangeDeclare(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Declare an exchange, via an interface that allows the complete set of arguments.
exchangeDeclare(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclare(String, String, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Declare an exchange.
exchangeDeclare(String, String, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Declare an exchange.
exchangeDeclare(String, String, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclareNoWait(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Like Channel.exchangeDeclare(String, String, boolean, boolean, java.util.Map) but sets nowait parameter to true and returns nothing (as there will be no response from the server).
exchangeDeclareNoWait(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
exchangeDeclareNoWait(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Like Channel.exchangeDeclare(String, String, boolean, boolean, java.util.Map) but sets nowait parameter to true and returns nothing (as there will be no response from the server).
exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeclarePassive(String) - Method in interface com.rabbitmq.client.Channel: Declare an exchange passively; that is, check if the named exchange exists.
exchangeDeclarePassive(String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Declare an exchange passively; that is, check if the named exchange exists.
exchangeDeclarePassive(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDelete(String) - Method in interface com.rabbitmq.client.Channel: Delete an exchange, without regard for whether it is in use or not
exchangeDelete(String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Delete an exchange, without regard for whether it is in use or not
exchangeDelete(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDelete(String, boolean) - Method in interface com.rabbitmq.client.Channel: Delete an exchange
exchangeDelete(String, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Delete an exchange
exchangeDelete(String, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeDeleteNoWait(String, boolean) - Method in interface com.rabbitmq.client.Channel: Like Channel.exchangeDelete(String, boolean) but sets nowait parameter to true and returns void (as there will be no response from the server).
exchangeDeleteNoWait(String, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Like Channel.exchangeDelete(String, boolean) but sets nowait parameter to true and returns void (as there will be no response from the server).
exchangeDeleteNoWait(String, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeRecoveryRetryCondition - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
exchangeRecoveryRetryCondition - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
exchangeRecoveryRetryCondition(BiPredicate<? super RecordedExchange, Exception>) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
exchangeRecoveryRetryOperation - Variable in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
exchangeRecoveryRetryOperation - Variable in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
exchangeRecoveryRetryOperation(DefaultRetryHandler.RetryOperation<?>) - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
exchangeUnbind(String, String, String) - Method in interface com.rabbitmq.client.Channel: Unbind an exchange from an exchange, with no extra arguments.
exchangeUnbind(String, String, String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Unbind an exchange from an exchange, with no extra arguments.
exchangeUnbind(String, String, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeUnbind(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Unbind an exchange from an exchange.
exchangeUnbind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Unbind an exchange from an exchange.
exchangeUnbind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
exchangeUnbindNoWait(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel: Same as Channel.exchangeUnbind(String, String, String, java.util.Map) but sets no-wait parameter to true and returns nothing (as there will be no response from the server).
exchangeUnbindNoWait(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Same as Channel.exchangeUnbind(String, String, String, java.util.Map) but sets no-wait parameter to true and returns nothing (as there will be no response from the server).
exchangeUnbindNoWait(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
excludeQueueFromRecovery(String, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Exclude the queue from the list of queues to recover after connection failure.
exclusive() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
exclusive() - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
exclusive() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
exclusive(boolean) - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
exclusive(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
exclusive(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
exclusive(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
exclusive(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
exnWrappingAsyncRpc(Method) - Method in class com.rabbitmq.client.impl.AMQChannel
exnWrappingRpc(Method) - Method in class com.rabbitmq.client.impl.AMQChannel: Placeholder until we address bug 15786 (implementing a proper exception hierarchy).
expiration(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
ExponentialBackoffDelayHandler() - Constructor for class com.rabbitmq.client.RecoveryDelayHandler.ExponentialBackoffDelayHandler: Default Constructor.
ExponentialBackoffDelayHandler(List<Long>) - Constructor for class com.rabbitmq.client.RecoveryDelayHandler.ExponentialBackoffDelayHandler: Constructor for passing your own backoff sequence
extensionPrettyPrint(String, byte[], X509Certificate) - Static method in class com.rabbitmq.client.impl.TlsUtils: Human-readable representation of an X509 certificate extension.
EXTERNAL - Static variable in class com.rabbitmq.client.DefaultSaslConfig
ExternalMechanism - Class in com.rabbitmq.client.impl: The EXTERNAL auth mechanism
ExternalMechanism() - Constructor for class com.rabbitmq.client.impl.ExternalMechanism
extractResponseBody(InputStream) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider

F

FAILED_TO_PUBLISH_MESSAGES - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
FANOUT - Enum constant in enum com.rabbitmq.client.BuiltinExchangeType
fill(Object, Map<String, Object>) - Static method in class com.rabbitmq.tools.json.JSONUtil: Uses reflection to fill public fields and Bean properties of the target object from the source Map.
fill(Object, Map<String, Object>, boolean) - Static method in class com.rabbitmq.tools.json.JSONUtil: Uses reflection to fill public fields and optionally Bean properties of the target object from the source Map.
filterBinding(RecordedBinding) - Method in interface com.rabbitmq.client.impl.recovery.TopologyRecoveryFilter: Decides whether a binding is recovered or not.
filterConsumer(RecordedConsumer) - Method in interface com.rabbitmq.client.impl.recovery.TopologyRecoveryFilter: Decides whether a consumer is recovered or not.
filterExchange(RecordedExchange) - Method in interface com.rabbitmq.client.impl.recovery.TopologyRecoveryFilter: Decides whether an exchange is recovered or not.
filterQueue(RecordedQueue) - Method in interface com.rabbitmq.client.impl.recovery.TopologyRecoveryFilter: Decides whether a queue is recovered or not.
finishPresence() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
finishPresence() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
finishWorkBlock(K) - Method in class com.rabbitmq.client.impl.WorkPool: Set client no longer in progress.
fixedDelayBeforeExpirationRefreshDelayStrategy(Duration) - Static method in class com.rabbitmq.client.impl.DefaultCredentialsRefreshService: Delay before refresh is time before expiration - specified duration.
fixedTimeApproachingExpirationStrategy(Duration) - Static method in class com.rabbitmq.client.impl.DefaultCredentialsRefreshService: Advise to refresh credentials if TTL <= limit.
fixStackTrace(T) - Static method in class com.rabbitmq.utility.Utility
Flow(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
Flow(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
FlowOk(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
FlowOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
flush() - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - flush the output buffers
flush() - Method in interface com.rabbitmq.client.impl.FrameHandler: Flush the underlying data connection.
flush() - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - call this to ensure all accumulated argument values are correctly written to the output stream.
flush() - Method in class com.rabbitmq.client.impl.nio.ByteBufferOutputStream
flush() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
flush() - Method in class com.rabbitmq.client.impl.nio.SslEngineByteBufferOutputStream
flush() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
flush() - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - call this to ensure all accumulated values are correctly written to the output stream.
ForgivingExceptionHandler - Class in com.rabbitmq.client.impl: An implementation of ExceptionHandler that does not close channels on unhandled consumer and listener exception.
ForgivingExceptionHandler() - Constructor for class com.rabbitmq.client.impl.ForgivingExceptionHandler
Frame - Class in com.rabbitmq.client.impl: Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.
Frame(int, int) - Constructor for class com.rabbitmq.client.impl.Frame: Constructs a frame for output with a type and a channel number and a fresh accumulator waiting for payload.
Frame(int, int, byte[]) - Constructor for class com.rabbitmq.client.impl.Frame: Constructs a frame for input with a type, a channel number and a payload byte array.
FRAME_BODY - Static variable in interface com.rabbitmq.client.AMQP
FRAME_END - Static variable in interface com.rabbitmq.client.AMQP
FRAME_ERROR - Static variable in interface com.rabbitmq.client.AMQP
FRAME_HEADER - Static variable in interface com.rabbitmq.client.AMQP
FRAME_HEARTBEAT - Static variable in interface com.rabbitmq.client.AMQP
FRAME_METHOD - Static variable in interface com.rabbitmq.client.AMQP
FRAME_MIN_SIZE - Static variable in interface com.rabbitmq.client.AMQP
FrameBuilder - Class in com.rabbitmq.client.impl.nio: Class to create AMQP frames from a ReadableByteChannel.
FrameBuilder(ReadableByteChannel, ByteBuffer) - Constructor for class com.rabbitmq.client.impl.nio.FrameBuilder
FrameHandler - Interface in com.rabbitmq.client.impl: Interface to a frame handler.
FrameHandlerFactory - Interface in com.rabbitmq.client.impl
frameMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
frameMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
FrameWriteRequest - Class in com.rabbitmq.client.impl.nio
FrameWriteRequest(Frame) - Constructor for class com.rabbitmq.client.impl.nio.FrameWriteRequest
free(int) - Method in class com.rabbitmq.utility.IntAllocator: Make the provided integer available for allocation again.
fromBodyFragment(int, byte[], int, int) - Static method in class com.rabbitmq.client.impl.Frame
fromSrvQueryResult(String) - Static method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord

G

get() - Method in class com.rabbitmq.utility.BlockingCell: Wait for a value, and when one arrives, return it (without clearing it).
get(long) - Method in class com.rabbitmq.utility.BlockingCell: Wait for a value, and when one arrives, return it (without clearing it).
Get(int, String, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Get
Get(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Get
getAcceptedIssuers() - Method in class com.rabbitmq.client.TrustEverythingTrustManager: Always returns an empty array of X509Certificates.
getAccess() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.Token
getAckedPublishedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getAcknowledgedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getAcknowledgedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getActive() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getActive() - Method in interface com.rabbitmq.client.AMQP.Channel.Flow
getActive() - Method in interface com.rabbitmq.client.AMQP.Channel.FlowOk
getActive() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
getActive() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
getActive() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
getActiveDeliveryTagOffset() - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
getAddress() - Method in interface com.rabbitmq.client.Connection: Retrieve the host.
getAddress() - Method in class com.rabbitmq.client.impl.AMQConnection: Retrieve the host.
getAddress() - Method in interface com.rabbitmq.client.impl.NetworkConnection: Retrieve address of peer.
getAddress() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
getAddress() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getAddress() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
getAddresses() - Method in interface com.rabbitmq.client.AddressResolver: Get the potential Addresses to connect to.
getAddresses() - Method in class com.rabbitmq.client.DnsRecordIpAddressResolver: Get the IP addresses from a DNS query
getAddresses() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver
getAddresses() - Method in class com.rabbitmq.client.ListAddressResolver
getAppId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getAppId() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the appId field.
getArguments() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getArguments() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
getArguments() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getArguments() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
getArguments() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
getArguments() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getArguments() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getArguments() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
getArguments() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
getArguments() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
getAutoDelete() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getAutoDelete() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getAutoDelete() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getAutoDelete() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getBody() - Method in class com.rabbitmq.client.Delivery: Retrieve the message body.
getBody() - Method in class com.rabbitmq.client.GetResponse: Get the message body included in this response
getBody() - Method in class com.rabbitmq.client.Return
getBody() - Method in class com.rabbitmq.client.RpcClient.Response
getBodySize() - Method in class com.rabbitmq.client.impl.AMQContentHeader
getByteBufferFactory() - Method in class com.rabbitmq.client.impl.nio.NioParams
getBytes() - Method in interface com.rabbitmq.client.LongString: Get the content as a byte array.
getCapabilities() - Method in interface com.rabbitmq.client.AMQP.Connection.Open
getCapabilities() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
getChallenge() - Method in interface com.rabbitmq.client.AMQP.Connection.Secure
getChallenge() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
getChannel() - Method in exception com.rabbitmq.client.ChannelContinuationTimeoutException: channel that performed the call
getChannel() - Method in class com.rabbitmq.client.DefaultConsumer: Retrieve the channel.
getChannel() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
getChannel() - Method in class com.rabbitmq.client.impl.recovery.RecordedEntity
getChannel() - Method in class com.rabbitmq.client.RpcClient: Retrieve the channel.
getChannel() - Method in class com.rabbitmq.client.RpcClientParams: Set the channel to use for communication.
getChannel() - Method in class com.rabbitmq.client.RpcServer: Retrieve the channel.
getChannel(int) - Method in class com.rabbitmq.client.impl.ChannelManager: Looks up a channel on this connection.
getChannelId() - Method in interface com.rabbitmq.client.AMQP.Channel.OpenOk
getChannelId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
getChannelMax() - Method in interface com.rabbitmq.client.AMQP.Connection.Tune
getChannelMax() - Method in interface com.rabbitmq.client.AMQP.Connection.TuneOk
getChannelMax() - Method in interface com.rabbitmq.client.Connection: Get the negotiated maximum channel number.
getChannelMax() - Method in class com.rabbitmq.client.impl.AMQConnection: Get the negotiated maximum channel number.
getChannelMax() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
getChannelMax() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
getChannelMax() - Method in class com.rabbitmq.client.impl.ChannelManager
getChannelMax() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getChannelNumber() - Method in interface com.rabbitmq.client.Channel: Retrieve this channel's channel number.
getChannelNumber() - Method in exception com.rabbitmq.client.ChannelContinuationTimeoutException
getChannelNumber() - Method in class com.rabbitmq.client.impl.AMQChannel: Public API - Retrieves this channel's channel number.
getChannelNumber() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getChannelRpcTimeout() - Method in class com.rabbitmq.client.ConnectionFactory: Get the timeout for RPC calls in channels.
getChannelRpcTimeout() - Method in class com.rabbitmq.client.impl.AMQConnection
getChannelRpcTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
getChannels() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getChannels() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
getChannels() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getClassId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getClassId() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
getClassId() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
getClassId() - Method in interface com.rabbitmq.client.ContentHeader: Retrieve the class ID (see the spec for a list of allowable IDs).
getClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
getClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
getClassName() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getClassName() - Method in interface com.rabbitmq.client.ContentHeader: Retrieve the class name, eg "basic" (see the spec for a list of these).
getClientMajor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException: The client's AMQP specification major version.
getClientMinor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException: The client's AMQP specification minor version.
getClientProperties() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
getClientProperties() - Method in interface com.rabbitmq.client.Connection: Get a copy of the map of client properties sent to the server
getClientProperties() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the currently-configured table of client properties that will be sent to the server during connection startup.
getClientProperties() - Method in class com.rabbitmq.client.impl.AMQConnection
getClientProperties() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
getClientProperties() - Method in class com.rabbitmq.client.impl.ConnectionParams
getClientProperties() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getClientProvidedName() - Method in interface com.rabbitmq.client.Connection: Returns client-provided connection name, if any.
getClientProvidedName() - Method in class com.rabbitmq.client.impl.AMQConnection
getClientProvidedName() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getClientVersion() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException: The client's AMQP specification version.
getCloseReason() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getCloseReason() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getCloseReason() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
getCloseReason() - Method in interface com.rabbitmq.client.ShutdownNotifier: Get the shutdown reason object
getClusterId() - Method in interface com.rabbitmq.client.AMQP.Basic.GetEmpty
getClusterId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getClusterId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
getCode() - Method in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
getConnection() - Method in interface com.rabbitmq.client.Channel: Retrieve the connection which carries this channel.
getConnection() - Method in class com.rabbitmq.client.impl.AMQChannel
getConnection() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
getConnection() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getConnectionRecoveryTriggeringCondition() - Method in class com.rabbitmq.client.impl.ConnectionParams
getConnections() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getConnections() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
getConnections() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getConnectionShutdownExecutor() - Method in class com.rabbitmq.client.impl.nio.NioParams
getConnectionTimeout() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the TCP connection timeout.
getConsumedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getConsumedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getConsumer() - Method in class com.rabbitmq.client.RpcClient: Retrieve the consumer.
getConsumerCount() - Method in interface com.rabbitmq.client.AMQP.Queue.DeclareOk
getConsumerCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Cancel
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.CancelOk
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.ConsumeOk
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
getConsumerTag() - Method in class com.rabbitmq.client.DefaultConsumer: Retrieve the consumer tag.
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
getConsumerTag() - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
getConsumerTag() - Method in class com.rabbitmq.client.RpcClient.Response
getConsumerTag() - Method in interface com.rabbitmq.client.RpcServer.RpcConsumer
getConsumerWorkServiceExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams
getContentBody() - Method in interface com.rabbitmq.client.Command: Retrieves the body byte array that travelled as part of this Command, if any.
getContentBody() - Method in class com.rabbitmq.client.impl.AMQCommand: Public API - Retrieves the body byte array that travelled as part of this Command, if any.
getContentEncoding() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getContentEncoding() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the contentEncoding field.
getContentHeader() - Method in interface com.rabbitmq.client.Command: Retrieves the ContentHeader subclass instance held as part of this Command, if any.
getContentHeader() - Method in class com.rabbitmq.client.impl.AMQCommand: Public API - Retrieves the ContentHeader subclass instance held as part of this Command, if any.
getContentType() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getContentType() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the contentType field.
getContinuationMap() - Method in class com.rabbitmq.client.RpcClient: Retrieve the continuation map.
getCorrelationId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getCorrelationId() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the correlationId field.
getCorrelationId() - Method in class com.rabbitmq.client.RpcClient: Retrieve the last correlation id used.
getCorrelationIdSupplier() - Method in class com.rabbitmq.client.RpcClientParams
getCredentialsProvider() - Method in class com.rabbitmq.client.impl.ConnectionParams
getCredentialsRefreshService() - Method in class com.rabbitmq.client.impl.ConnectionParams
getDefaultConsumer() - Method in interface com.rabbitmq.client.Channel: Get the current default consumer.
getDefaultConsumer() - Method in class com.rabbitmq.client.impl.ChannelN: Returns the current default consumer.
getDefaultConsumer() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getDelay(int) - Method in class com.rabbitmq.client.RecoveryDelayHandler.DefaultRecoveryDelayHandler
getDelay(int) - Method in class com.rabbitmq.client.RecoveryDelayHandler.ExponentialBackoffDelayHandler
getDelay(int) - Method in interface com.rabbitmq.client.RecoveryDelayHandler: Get the time to sleep (in milliseconds) before attempting to reconnect and recover again.
getDelegate() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getDelegate() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Not supposed to be used outside of automated tests.
getDelegateChannel() - Method in class com.rabbitmq.client.impl.recovery.RecordedEntity
getDeliveryMode() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getDeliveryMode() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the deliveryMode field.
getDeliveryTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Ack
getDeliveryTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
getDeliveryTag() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
getDeliveryTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Nack
getDeliveryTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Reject
getDeliveryTag() - Method in class com.rabbitmq.client.Envelope: Get the delivery tag included in this parameter envelope
getDeliveryTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
getDeliveryTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
getDeliveryTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getDeliveryTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
getDeliveryTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
getDestination() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
getDestination() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
getDestination() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
getDestination() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
getDestination() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
getDurable() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getDurable() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getDurable() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getDurable() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
GetEmpty(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
GetEmpty(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
getEnvelope() - Method in class com.rabbitmq.client.Delivery: Retrieve the message envelope.
getEnvelope() - Method in class com.rabbitmq.client.GetResponse: Get the Envelope included in this response
getEnvelope() - Method in class com.rabbitmq.client.RpcClient.Response
getError() - Method in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
getError() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcResponse
getErrorOnWriteListener() - Method in class com.rabbitmq.client.impl.ConnectionParams
getException() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcResponse
getExceptionHandler() - Method in interface com.rabbitmq.client.Connection: Get the exception handler.
getExceptionHandler() - Method in class com.rabbitmq.client.ConnectionFactory: Get the exception handler.
getExceptionHandler() - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - retrieve the current ExceptionHandler
getExceptionHandler() - Method in class com.rabbitmq.client.impl.ConnectionParams
getExceptionHandler() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.Return
getExchange() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getExchange() - Method in interface com.rabbitmq.client.AMQP.Exchange.Delete
getExchange() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
getExchange() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
getExchange() - Method in class com.rabbitmq.client.Envelope: Get the name of the exchange included in this parameter envelope
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
getExchange() - Method in class com.rabbitmq.client.Return
getExchange() - Method in class com.rabbitmq.client.RpcClient: Retrieve the exchange.
getExchange() - Method in class com.rabbitmq.client.RpcClientParams: Set the exchange to send requests to.
getExclusive() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getExclusive() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getExclusive() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getExclusive() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
getExclusive() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getExclusive() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getExpectedFrameType() - Method in exception com.rabbitmq.client.UnexpectedFrameError
getExpiration() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getExpiration() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the expiration field.
getExpiresIn() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.Token
getFailedToPublishMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getFailedToPublishMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getFrameHandler() - Method in class com.rabbitmq.client.impl.AMQConnection
getFrameMax() - Method in interface com.rabbitmq.client.AMQP.Connection.Tune
getFrameMax() - Method in interface com.rabbitmq.client.AMQP.Connection.TuneOk
getFrameMax() - Method in interface com.rabbitmq.client.Connection: Get the negotiated maximum frame size.
getFrameMax() - Method in class com.rabbitmq.client.impl.AMQConnection: Get the negotiated maximum frame size.
getFrameMax() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
getFrameMax() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
getFrameMax() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getGlobal() - Method in interface com.rabbitmq.client.AMQP.Basic.Qos
getGlobal() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
getHandshakeTimeout() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the AMQP 0-9-1 protocol handshake timeout.
getHandshakeTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
getHeaders() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getHeaders() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the table in the headers field as a map of fields names and values.
getHeartbeat() - Method in interface com.rabbitmq.client.AMQP.Connection.Tune
getHeartbeat() - Method in interface com.rabbitmq.client.AMQP.Connection.TuneOk
getHeartbeat() - Method in interface com.rabbitmq.client.Connection: Get the negotiated heartbeat interval.
getHeartbeat() - Method in class com.rabbitmq.client.impl.AMQConnection: Get the negotiated heartbeat interval.
getHeartbeat() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
getHeartbeat() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
getHeartbeat() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getHeartbeatExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams
getHelp() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
getHelp() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
getHost() - Method in class com.rabbitmq.client.Address: Get the host name
getHost() - Method in class com.rabbitmq.client.ConnectionFactory
getHost() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
getId() - Method in interface com.rabbitmq.client.Connection: Returns a unique ID for this connection.
getId() - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - Returns a unique ID for this connection.
getId() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Public API - Returns a unique ID for this connection.
getId() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
getId() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
getIfEmpty() - Method in interface com.rabbitmq.client.AMQP.Queue.Delete
getIfEmpty() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
getIfUnused() - Method in interface com.rabbitmq.client.AMQP.Exchange.Delete
getIfUnused() - Method in interface com.rabbitmq.client.AMQP.Queue.Delete
getIfUnused() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
getIfUnused() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
getImmediate() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
getImmediate() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
getIndentMode() - Method in class com.rabbitmq.tools.json.JSONWriter: Deprecated.
getInputStream() - Method in class com.rabbitmq.client.impl.Frame: Public API - retrieves a new DataInputStream streaming over the payload
getInputStream() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
getInsist() - Method in interface com.rabbitmq.client.AMQP.Connection.Open
getInsist() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
getInternal() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getInternal() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getJavaReturnType() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
getKnownHosts() - Method in interface com.rabbitmq.client.AMQP.Connection.OpenOk
getKnownHosts() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
getLastActivity() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
getLocalAddress() - Method in class com.rabbitmq.client.impl.AMQConnection
getLocalAddress() - Method in interface com.rabbitmq.client.impl.NetworkConnection: Retrieve the local host.
getLocalAddress() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
getLocalAddress() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getLocalAddress() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
getLocale() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
getLocale() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
getLocales() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getLocales() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
getLocalPort() - Method in class com.rabbitmq.client.impl.AMQConnection
getLocalPort() - Method in interface com.rabbitmq.client.impl.NetworkConnection: Retrieve the local port number.
getLocalPort() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
getLocalPort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getLocalPort() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
getMajor() - Method in class com.rabbitmq.client.impl.Version: Retrieve the major version number.
getMandatory() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
getMandatory() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
getMaxSeenDeliveryTag() - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
getMechanism() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
getMechanism() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
getMechanisms() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getMechanisms() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
getMessage() - Method in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Queue.DeclareOk
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Queue.DeleteOk
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Queue.PurgeOk
getMessageCount() - Method in class com.rabbitmq.client.GetResponse: Get the server's most recent estimate of the number of messages remaining on the queue.
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
getMessageId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getMessageId() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the messageId field.
getMethod() - Method in exception com.rabbitmq.client.ChannelContinuationTimeoutException
getMethod() - Method in interface com.rabbitmq.client.Command: Retrieves the Method held within this Command.
getMethod() - Method in class com.rabbitmq.client.impl.AMQCommand: Public API - Retrieves the Method held within this Command.
getMethod() - Method in exception com.rabbitmq.client.UnexpectedMethodError: Return the wrapped method.
getMethod() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
getMethodId() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
getMethodId() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
getMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
getMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
getMetricRegistry() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getMetricsCollector() - Method in class com.rabbitmq.client.ConnectionFactory
getMinor() - Method in class com.rabbitmq.client.impl.Version: Retrieve the minor version number.
getMultiple() - Method in interface com.rabbitmq.client.AMQP.Basic.Ack
getMultiple() - Method in interface com.rabbitmq.client.AMQP.Basic.Nack
getMultiple() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
getMultiple() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
getNackedPublishedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getName() - Method in class com.rabbitmq.client.impl.CRDemoMechanism
getName() - Method in class com.rabbitmq.client.impl.ExternalMechanism
getName() - Method in class com.rabbitmq.client.impl.PlainMechanism
getName() - Method in class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
getName() - Method in interface com.rabbitmq.client.SaslMechanism: The name of this mechanism (e.g.
getName() - Method in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
getName() - Method in class com.rabbitmq.tools.jsonrpc.ParameterDescription
getName() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
getName() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
getNameToUseForRecovery() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
getNameToUseForRecovery(RecordedQueue) - Method in interface com.rabbitmq.client.impl.recovery.RecoveredQueueNameSupplier: Get the queue name to use when recovering this RecordedQueue entity
getNbIoThreads() - Method in class com.rabbitmq.client.impl.nio.NioParams
getNetworkRecoveryInterval() - Method in class com.rabbitmq.client.ConnectionFactory: Returns automatic connection recovery interval in milliseconds.
getNetworkRecoveryInterval() - Method in class com.rabbitmq.client.impl.ConnectionParams
getNewSecret() - Method in interface com.rabbitmq.client.AMQP.Connection.UpdateSecret
getNewSecret() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
getNextPublishSeqNo() - Method in interface com.rabbitmq.client.Channel: When in confirm mode, returns the sequence number of the next message to be published.
getNextPublishSeqNo() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - When in confirm mode, returns the sequence number of the next message to be published.
getNextPublishSeqNo() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getNioExecutor() - Method in class com.rabbitmq.client.impl.nio.NioParams
getNioParams() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the parameters for NIO mode.
getNioParams() - Method in class com.rabbitmq.client.impl.nio.NioContext: NIO params.
getNoAck() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getNoAck() - Method in interface com.rabbitmq.client.AMQP.Basic.Get
getNoAck() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getNoAck() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
getNoLocal() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getNoLocal() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getNowait() - Method in interface com.rabbitmq.client.AMQP.Basic.Cancel
getNowait() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getNowait() - Method in interface com.rabbitmq.client.AMQP.Confirm.Select
getNowait() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
getNowait() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getNowait() - Method in interface com.rabbitmq.client.AMQP.Exchange.Delete
getNowait() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
getNowait() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
getNowait() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getNowait() - Method in interface com.rabbitmq.client.AMQP.Queue.Delete
getNowait() - Method in interface com.rabbitmq.client.AMQP.Queue.Purge
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
getNowait() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
GetOk(long, boolean, String, String, int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
GetOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getOutOfBand() - Method in interface com.rabbitmq.client.AMQP.Channel.Open
getOutOfBand() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
getOutputStream() - Method in class com.rabbitmq.client.impl.Frame: Public API - retrieves a fresh DataOutputStream streaming into the accumulator
getParameters() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
getParams() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
getPassive() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getPassive() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getPassive() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getPassive() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
getPassive() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getPassive() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getPassword() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the password.
getPassword() - Method in interface com.rabbitmq.client.impl.CredentialsProvider: Password/secret/token to use for authentication
getPassword() - Method in class com.rabbitmq.client.impl.DefaultCredentialsProvider
getPassword() - Method in class com.rabbitmq.client.impl.RefreshProtectedCredentialsProvider
getPayload() - Method in class com.rabbitmq.client.impl.Frame: Public API - retrieves the frame payload
getPort() - Method in class com.rabbitmq.client.Address: Get the port number
getPort() - Method in interface com.rabbitmq.client.Connection: Retrieve the port number.
getPort() - Method in class com.rabbitmq.client.ConnectionFactory
getPort() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
getPort() - Method in class com.rabbitmq.client.impl.AMQConnection: Retrieve the port number.
getPort() - Method in interface com.rabbitmq.client.impl.NetworkConnection: Retrieve port number of peer.
getPort() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
getPort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getPort() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
getPrefetchCount() - Method in interface com.rabbitmq.client.AMQP.Basic.Qos
getPrefetchCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
getPrefetchSize() - Method in interface com.rabbitmq.client.AMQP.Basic.Qos
getPrefetchSize() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
getPriority() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getPriority() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the priority field.
getPriority() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
getProcedure(String, int) - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription: Looks up a single ProcedureDescription by name and arity.
getProcs() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription: Gets a collection of all ProcedureDescription for this service
getProperties() - Method in class com.rabbitmq.client.Delivery: Retrieve the message properties.
getProperties() - Method in class com.rabbitmq.client.Return
getProperties() - Method in class com.rabbitmq.client.RpcClient.Response
getProps() - Method in class com.rabbitmq.client.GetResponse: Get the AMQP.BasicProperties included in this response
getPublishAcknowledgedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getPublishedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getPublishedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getPublishNotAcknowledgedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getPublishUnroutedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getQueue() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getQueue() - Method in interface com.rabbitmq.client.AMQP.Basic.Get
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.DeclareOk
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Delete
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Purge
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
getQueue() - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
getQueueName() - Method in class com.rabbitmq.client.RpcServer: Retrieve the queue name.
getRead() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getRead() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
getReadByteBufferSize() - Method in class com.rabbitmq.client.impl.nio.NioParams
getRealm() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getRealm() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
getReason() - Method in interface com.rabbitmq.client.AMQP.Connection.Blocked
getReason() - Method in interface com.rabbitmq.client.AMQP.Connection.UpdateSecret
getReason() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
getReason() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
getReason() - Method in exception com.rabbitmq.client.ShutdownSignalException
getReceivedAt() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.Token
getReceivedFrame() - Method in exception com.rabbitmq.client.UnexpectedFrameError
getRecordedBindings() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getRecordedConsumers() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getRecordedEntity() - Method in class com.rabbitmq.client.impl.recovery.RetryResult: The entity to recover.
getRecordedEntity() - Method in exception com.rabbitmq.client.TopologyRecoveryException
getRecordedExchanges() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getRecordedQueues() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getRecoveredQueueNameSupplier() - Method in class com.rabbitmq.client.impl.ConnectionParams
getRecoveryDelayHandler() - Method in class com.rabbitmq.client.ConnectionFactory: Returns automatic connection recovery delay handler.
getRecoveryDelayHandler() - Method in class com.rabbitmq.client.impl.ConnectionParams: Get the recovery delay handler.
getRedelivered() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
getRedelivered() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
getRedelivered() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
getRedelivered() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getReference() - Method in exception com.rabbitmq.client.ShutdownSignalException
getRejectedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getRejectedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
getReply() - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
getReply(int) - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
getReplyCode() - Method in interface com.rabbitmq.client.AMQP.Basic.Return
getReplyCode() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
getReplyCode() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
getReplyCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
getReplyCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
getReplyCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
getReplyCode() - Method in class com.rabbitmq.client.Return
getReplyHandler() - Method in class com.rabbitmq.client.RpcClientParams
getReplyText() - Method in interface com.rabbitmq.client.AMQP.Basic.Return
getReplyText() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
getReplyText() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
getReplyText() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
getReplyText() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
getReplyText() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
getReplyText() - Method in class com.rabbitmq.client.Return
getReplyTo() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getReplyTo() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the replyTo field.
getReplyTo() - Method in class com.rabbitmq.client.RpcClientParams
getRequestedChannelMax() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the requested maximum channel number
getRequestedChannelMax() - Method in class com.rabbitmq.client.impl.ConnectionParams
getRequestedFrameMax() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the requested maximum frame size
getRequestedFrameMax() - Method in class com.rabbitmq.client.impl.ConnectionParams
getRequestedHeartbeat() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the requested heartbeat interval.
getRequestedHeartbeat() - Method in class com.rabbitmq.client.impl.ConnectionParams
getRequeue() - Method in interface com.rabbitmq.client.AMQP.Basic.Nack
getRequeue() - Method in interface com.rabbitmq.client.AMQP.Basic.Recover
getRequeue() - Method in interface com.rabbitmq.client.AMQP.Basic.RecoverAsync
getRequeue() - Method in interface com.rabbitmq.client.AMQP.Basic.Reject
getRequeue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
getRequeue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
getRequeue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
getRequeue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
getResponse() - Method in interface com.rabbitmq.client.AMQP.Connection.SecureOk
getResponse() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
getResponse() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
getResponse() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
GetResponse - Class in com.rabbitmq.client: Encapsulates the response from a Channel.basicGet(java.lang.String, boolean) message-retrieval method call - essentially a static bean "holder" with message response data.
GetResponse(Envelope, AMQP.BasicProperties, byte[], int) - Constructor for class com.rabbitmq.client.GetResponse: Construct a GetResponse with the specified construction parameters
getResult() - Method in class com.rabbitmq.client.impl.recovery.RetryResult: The result of the recovery operation.
getResult() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcResponse
getReturn() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription: Getter for return type
getReturnMessage() - Method in exception com.rabbitmq.client.UnroutableRpcRequestException: The returned message.
getReturnType() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Basic.Return
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
getRoutingKey() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
getRoutingKey() - Method in class com.rabbitmq.client.Envelope: Get the routing key included in this parameter envelope
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
getRoutingKey() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
getRoutingKey() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
getRoutingKey() - Method in class com.rabbitmq.client.Return
getRoutingKey() - Method in class com.rabbitmq.client.RpcClient: Retrieve the routing key.
getRoutingKey() - Method in class com.rabbitmq.client.RpcClientParams
getSaslConfig() - Method in class com.rabbitmq.client.ConnectionFactory: Gets the sasl config to use when authenticating
getSaslConfig() - Method in class com.rabbitmq.client.impl.ConnectionParams
getSaslMechanism(String[]) - Method in class com.rabbitmq.client.DefaultSaslConfig
getSaslMechanism(String[]) - Method in class com.rabbitmq.client.impl.CRDemoMechanism.CRDemoSaslConfig
getSaslMechanism(String[]) - Method in class com.rabbitmq.client.JDKSaslConfig
getSaslMechanism(String[]) - Method in interface com.rabbitmq.client.SaslConfig
getSerialVersionUID() - Static method in exception com.rabbitmq.client.UnexpectedFrameError
getServerMajor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException: The server's AMQP specification major version.
getServerMinor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException: The server's AMQP specification minor version.
getServerProperties() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getServerProperties() - Method in interface com.rabbitmq.client.Connection: Retrieve the server properties.
getServerProperties() - Method in class com.rabbitmq.client.impl.AMQConnection: Retrieve the server properties.
getServerProperties() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
getServerProperties() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getServerVersion() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException: The server's AMQP specification version.
getServiceDescription() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Public API - gets the service description record that this service loaded from the server itself at construction time.
getServiceDescription() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Public API - gets the service description record that this service built from interfaceClass at construction time.
getShutdownExecutor() - Method in class com.rabbitmq.client.impl.ChannelManager
getShutdownExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams
getShutdownTimeout() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the shutdown timeout.
getShutdownTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
getShutdownTimeout() - Method in class com.rabbitmq.client.impl.ConsumerWorkService
getSocketChannelConfigurator() - Method in class com.rabbitmq.client.impl.nio.NioParams
getSocketConfigurator() - Method in class com.rabbitmq.client.ConnectionFactory: Get the socket configurator.
getSocketFactory() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the socket factory used to make connections with.
getSource() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
getSource() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
getSource() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
getSource() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
getSource() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
getSslEngine() - Method in class com.rabbitmq.client.impl.nio.NioContext: SSLEngine for SSL/TLS connection.
getSslEngineConfigurator() - Method in class com.rabbitmq.client.impl.nio.NioParams
getState() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
getStream() - Method in interface com.rabbitmq.client.LongString: Get the content stream.
getSummary() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
getSummary() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
getThreadFactory() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the thread factory used to instantiate new threads.
getThreadFactory() - Method in class com.rabbitmq.client.impl.AMQConnection
getThreadFactory() - Method in class com.rabbitmq.client.impl.ConnectionParams
getThreadFactory() - Method in class com.rabbitmq.client.impl.nio.NioParams
getTicket() - Method in interface com.rabbitmq.client.AMQP.Access.RequestOk
getTicket() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
getTicket() - Method in interface com.rabbitmq.client.AMQP.Basic.Get
getTicket() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
getTicket() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
getTicket() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getTicket() - Method in interface com.rabbitmq.client.AMQP.Exchange.Delete
getTicket() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
getTicket() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
getTicket() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
getTicket() - Method in interface com.rabbitmq.client.AMQP.Queue.Delete
getTicket() - Method in interface com.rabbitmq.client.AMQP.Queue.Purge
getTicket() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
getTicket() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
getTimeBeforeExpiration() - Method in interface com.rabbitmq.client.impl.CredentialsProvider: The time before the credentials expire, if they do expire.
getTimeBeforeExpiration() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.Token
getTimeBeforeExpiration() - Method in class com.rabbitmq.client.impl.RefreshProtectedCredentialsProvider
getTimeout() - Method in interface com.rabbitmq.client.impl.FrameHandler: Get the underlying socket's read timeout in milliseconds.
getTimeout() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
getTimeout() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
getTimeout() - Method in class com.rabbitmq.client.RpcClientParams
getTimestamp() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getTimestamp() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the timestamp field.
getTopologyRecoveryExecutor() - Method in class com.rabbitmq.client.ConnectionFactory: Get the executor to use for parallel topology recovery.
getTopologyRecoveryExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams: Get the topology recovery executor.
getTopologyRecoveryFilter() - Method in class com.rabbitmq.client.impl.ConnectionParams
getTopologyRecoveryRetryHandler() - Method in class com.rabbitmq.client.impl.ConnectionParams
getTrafficListener() - Method in class com.rabbitmq.client.impl.AMQConnection
getTrafficListener() - Method in class com.rabbitmq.client.impl.ConnectionParams
getType() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getType() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
getType() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the type field.
getType() - Method in enum com.rabbitmq.client.BuiltinExchangeType
getType() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
getType() - Method in class com.rabbitmq.tools.jsonrpc.ParameterDescription
getUnroutedPublishedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
getUserId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getUserId() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the userId field.
getUsername() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the user name.
getUsername() - Method in interface com.rabbitmq.client.impl.CredentialsProvider: Username to use for authentication
getUsername() - Method in class com.rabbitmq.client.impl.DefaultCredentialsProvider
getUsername() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
getUsername() - Method in class com.rabbitmq.client.impl.RefreshProtectedCredentialsProvider
getValue() - Method in class com.rabbitmq.utility.ValueOrException: Retrieve value or throw exception
getVersion() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
getVersion() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
getVersionMajor() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getVersionMajor() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
getVersionMinor() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getVersionMinor() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
getVirtualHost() - Method in interface com.rabbitmq.client.AMQP.Connection.Open
getVirtualHost() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the virtual host.
getVirtualHost() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
getVirtualHost() - Method in class com.rabbitmq.client.impl.ConnectionParams
getWeight() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
getWorkPoolTimeout() - Method in class com.rabbitmq.client.ConnectionFactory
getWorkPoolTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
getWrite() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getWrite() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
getWriteByteBufferSize() - Method in class com.rabbitmq.client.impl.nio.NioParams
getWriteEnqueuingTimeoutInMs() - Method in class com.rabbitmq.client.impl.nio.NioParams
getWriteQueue() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
getWriteQueueCapacity() - Method in class com.rabbitmq.client.impl.nio.NioParams
getWriteQueueFactory() - Method in class com.rabbitmq.client.impl.nio.NioParams
global() - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
global(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
grantType(String) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder: Set the grant type to use when requesting the token.

H

handle() - Method in interface com.rabbitmq.client.UnblockedCallback
handle(long, boolean) - Method in interface com.rabbitmq.client.ConfirmCallback
handle(Connection, IOException) - Method in interface com.rabbitmq.client.impl.ErrorOnWriteListener: Called when writing to the socket failed
handle(Return) - Method in interface com.rabbitmq.client.ReturnCallback
handle(DataOutputStream) - Method in class com.rabbitmq.client.impl.nio.FrameWriteRequest
handle(DataOutputStream) - Method in class com.rabbitmq.client.impl.nio.HeaderWriteRequest
handle(DataOutputStream) - Method in interface com.rabbitmq.client.impl.nio.WriteRequest
handle(String) - Method in interface com.rabbitmq.client.BlockedCallback
handle(String) - Method in interface com.rabbitmq.client.CancelCallback: Called when the consumer is cancelled for reasons other than by a call to Channel.basicCancel(java.lang.String).
handle(String, Delivery) - Method in interface com.rabbitmq.client.DeliverCallback: Called when a basic.deliver is received for this consumer.
handleAck(long, boolean) - Method in interface com.rabbitmq.client.ConfirmListener
handleBlocked(String) - Method in interface com.rabbitmq.client.BlockedListener
handleBlockedListenerException(Connection, Throwable) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has called a BlockedListener's method, and that method has thrown an exception.
handleBlockedListenerException(Connection, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleBlockedListenerException(Connection, Throwable) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
handleCall(byte[], AMQP.BasicProperties) - Method in class com.rabbitmq.client.MapRpcServer: Overridden to delegate to handleMapCall.
handleCall(byte[], AMQP.BasicProperties) - Method in class com.rabbitmq.client.RpcServer: High-level response method.
handleCall(byte[], AMQP.BasicProperties) - Method in class com.rabbitmq.client.StringRpcServer: Overridden to do UTF-8 processing, and delegate to handleStringCall.
handleCall(AMQP.BasicProperties, byte[], AMQP.BasicProperties) - Method in class com.rabbitmq.client.RpcServer: Mid-level response method.
handleCall(Delivery, AMQP.BasicProperties) - Method in class com.rabbitmq.client.RpcServer: Lowest-level response method.
handleCancel(String) - Method in interface com.rabbitmq.client.Consumer: Called when the consumer is cancelled for reasons other than by a call to Channel.basicCancel(java.lang.String).
handleCancel(String) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleCancel(String)
handleCancelOk(String) - Method in interface com.rabbitmq.client.Consumer: Called when the consumer is cancelled by a call to Channel.basicCancel(java.lang.String).
handleCancelOk(String) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleCancelOk(java.lang.String).
handleCast(byte[]) - Method in class com.rabbitmq.client.MapRpcServer: Overridden to delegate to handleMapCast.
handleCast(byte[]) - Method in class com.rabbitmq.client.RpcServer: High-level handler method.
handleCast(byte[]) - Method in class com.rabbitmq.client.StringRpcServer: Overridden to do UTF-8 processing, and delegate to handleStringCast.
handleCast(AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.RpcServer: Mid-level handler method.
handleCast(Delivery) - Method in class com.rabbitmq.client.RpcServer: Lowest-level handler method.
handleChallenge(LongString, String, String) - Method in class com.rabbitmq.client.impl.CRDemoMechanism
handleChallenge(LongString, String, String) - Method in class com.rabbitmq.client.impl.ExternalMechanism
handleChallenge(LongString, String, String) - Method in class com.rabbitmq.client.impl.PlainMechanism
handleChallenge(LongString, String, String) - Method in interface com.rabbitmq.client.SaslMechanism: Handle one round of challenge-response
handleChannelKiller(Channel, Throwable, String) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleChannelKiller(Channel, Throwable, String) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
handleChannelKiller(Channel, Throwable, String, String) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
handleChannelRecoveryException(Channel, Throwable) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has an exception during channel recovery that it can't otherwise deal with.
handleChannelRecoveryException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleCommand(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
handleCommand(AMQCommand) - Method in interface com.rabbitmq.client.impl.AMQChannel.RpcContinuation
handleCompleteInboundCommand(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel: Private API - handle a command which has been assembled
handleConfirmListenerException(Channel, Throwable) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has called a ConfirmListener's handleAck or handleNack method, and that method has thrown an exception.
handleConfirmListenerException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleConfirmListenerException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
handleConnectionClose(Command) - Method in class com.rabbitmq.client.impl.AMQConnection
handleConnectionKiller(Connection, Throwable, String) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleConnectionRecoveryException(Connection, Throwable) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has an exception during connection recovery that it can't otherwise deal with.
handleConnectionRecoveryException(Connection, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleConsumeOk(String) - Method in interface com.rabbitmq.client.Consumer: Called when the consumer is registered by a call to any of the Channel.basicConsume(java.lang.String, com.rabbitmq.client.Consumer) methods.
handleConsumeOk(String) - Method in class com.rabbitmq.client.DefaultConsumer: Stores the most recently passed-in consumerTag - semantically, there should be only one.
handleConsumerException(Channel, Throwable, Consumer, String, String) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has called a method on a Consumer, and that method has thrown an exception.
handleConsumerException(Channel, Throwable, Consumer, String, String) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleConsumerException(Channel, Throwable, Consumer, String, String) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
handleDelivery(String, Envelope, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Consumer: Called when a basic.deliver is received for this consumer.
handleDelivery(String, Envelope, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleDelivery(java.lang.String, com.rabbitmq.client.Envelope, com.rabbitmq.client.AMQP.BasicProperties, byte[]).
handleFrame(Frame) - Method in class com.rabbitmq.client.impl.AMQChannel: Private API - When the Connection receives a Frame for this channel, it passes it to this method.
handleFrame(Frame) - Method in class com.rabbitmq.client.impl.AMQCommand
handleHeartbeatFailure() - Method in class com.rabbitmq.client.impl.AMQConnection: private API
handleHeartbeatFailure(SocketChannelFrameHandlerState) - Method in class com.rabbitmq.client.impl.nio.NioLoop
handleIoError(SocketChannelFrameHandlerState, Throwable) - Method in class com.rabbitmq.client.impl.nio.NioLoop
handleIoError(Throwable) - Method in class com.rabbitmq.client.impl.AMQConnection: private API
handleMapCall(Map<String, Object>) - Method in class com.rabbitmq.client.MapRpcServer: Default implementation override in subclasses.
handleMapCall(Map<String, Object>, AMQP.BasicProperties) - Method in class com.rabbitmq.client.MapRpcServer: Delegates to MapRpcServer.handleMapCall(Map).
handleMapCast(Map<String, Object>) - Method in class com.rabbitmq.client.MapRpcServer: Default implementation override in subclasses.
handleNack(long, boolean) - Method in interface com.rabbitmq.client.ConfirmListener
handleReadFrame(Frame) - Method in class com.rabbitmq.client.impl.AMQConnection: private API
handleRecoverOk(String) - Method in interface com.rabbitmq.client.Consumer: Called when a basic.recover-ok is received in reply to a basic.recover.
handleRecoverOk(String) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleRecoverOk(java.lang.String).
handleRecovery(Recoverable) - Method in interface com.rabbitmq.client.RecoveryListener: Invoked when automatic connection recovery has completed.
handleRecoveryStarted(Recoverable) - Method in interface com.rabbitmq.client.RecoveryListener: Invoked before automatic connection recovery starts.
handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.ReturnListener
handleReturnListenerException(Channel, Throwable) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has called a ReturnListener's handleReturn method, and that method has thrown an exception.
handleReturnListenerException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleReturnListenerException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
handleShutdownSignal(ShutdownSignalException) - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
handleShutdownSignal(ShutdownSignalException) - Method in interface com.rabbitmq.client.impl.AMQChannel.RpcContinuation
handleShutdownSignal(String, ShutdownSignalException) - Method in interface com.rabbitmq.client.Consumer: Called when either the channel or the underlying connection has been shut down.
handleShutdownSignal(String, ShutdownSignalException) - Method in interface com.rabbitmq.client.ConsumerShutdownSignalCallback: Called when either the channel or the underlying connection has been shut down.
handleShutdownSignal(String, ShutdownSignalException) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleShutdownSignal(java.lang.String, com.rabbitmq.client.ShutdownSignalException).
handleSignal(ShutdownSignalException) - Method in class com.rabbitmq.client.impl.ChannelManager: Handle shutdown.
handleStringCall(String) - Method in class com.rabbitmq.client.StringRpcServer: Default implementation - override in subclasses.
handleStringCall(String, AMQP.BasicProperties) - Method in class com.rabbitmq.client.StringRpcServer: Delegates to handleStringCall(String).
handleStringCall(String, AMQP.BasicProperties) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Override our superclass' method, dispatching to doCall.
handleStringCast(String) - Method in class com.rabbitmq.client.StringRpcServer: Default implementation - override in subclasses.
handleTopologyRecoveryException(Connection, Channel, TopologyRecoveryException) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has an exception during topology (exchanges, queues, bindings, consumers) recovery that it can't otherwise deal with.
handleTopologyRecoveryException(Connection, Channel, TopologyRecoveryException) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleTopologyRecoveryStarted(Recoverable) - Method in interface com.rabbitmq.client.RecoveryListener: Invoked before automatic topology recovery starts.
handleUnblocked() - Method in interface com.rabbitmq.client.BlockedListener
handleUnexpectedConnectionDriverException(Connection, Throwable) - Method in interface com.rabbitmq.client.ExceptionHandler: Perform any required exception processing for the situation when the driver thread for the connection has an exception signalled to it that it can't otherwise deal with.
handleUnexpectedConnectionDriverException(Connection, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
HANDSHAKE_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
hasBrokerInitiatedShutdown() - Method in class com.rabbitmq.client.impl.AMQConnection
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecretOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
hasContent() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
hasContent() - Method in class com.rabbitmq.client.impl.Method: Tell if content is present.
hashCode() - Method in class com.rabbitmq.client.Address
hashCode() - Method in class com.rabbitmq.client.AMQP.BasicProperties
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
hashCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
hashCode() - Method in class com.rabbitmq.client.impl.nio.SocketChannelRegistration
hashCode() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
hashCode() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
hashCode() - Method in class com.rabbitmq.client.impl.Version
headers(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
HEADERS - Enum constant in enum com.rabbitmq.client.BuiltinExchangeType
HeaderWriteRequest - Class in com.rabbitmq.client.impl.nio
heartbeat(int) - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
heartbeat(int) - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
HOST - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
hostnameVerifier(HostnameVerifier) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration: Set the hostname verifier.

I

ifEmpty() - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
ifEmpty(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
ifUnused() - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
ifUnused() - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
ifUnused(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
ifUnused(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
immediate() - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
immediate(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Increments channel count.
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
incrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Increments connection count.
incrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
incrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
incrementConnectionCount(Connection) - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
incrementingCorrelationIdSupplier() - Static method in class com.rabbitmq.client.RpcClient: Creates generation IDs as a sequence of integers.
incrementingCorrelationIdSupplier(String) - Static method in class com.rabbitmq.client.RpcClient: Creates generation IDs as a sequence of integers, with the provided prefix.
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Access
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Access.Request
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Confirm
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecretOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
INDEX - Static variable in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
init() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection: Private API.
initialize(AMQConnection) - Method in interface com.rabbitmq.client.impl.FrameHandler
initialize(AMQConnection) - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
initialize(AMQConnection) - Method in class com.rabbitmq.client.impl.SocketFrameHandler
insist() - Method in class com.rabbitmq.client.AMQP.Connection.Open.Builder
insist(boolean) - Method in class com.rabbitmq.client.AMQP.Connection.Open.Builder
instantiateChannel(AMQConnection, int, ConsumerWorkService) - Method in class com.rabbitmq.client.impl.ChannelManager
instantiateChannel(AMQConnection, int, ConsumerWorkService) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelManager
instantiateChannelManager(int, ThreadFactory) - Method in class com.rabbitmq.client.impl.AMQConnection
instantiateChannelManager(int, ThreadFactory) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnection
IntAllocator - Class in com.rabbitmq.utility: A class for allocating integers from a given range that uses a BitSet representation of the free integers.
IntAllocator(int, int) - Constructor for class com.rabbitmq.utility.IntAllocator: Creates an IntAllocator allocating integer IDs within the inclusive range [bottom, top].
internal() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
internal(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
INTERNAL_ERROR - Static variable in interface com.rabbitmq.client.AMQP
internal_getMethod() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription: Private API - used to get the reflected method object, for servers
internal_getParams() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription: Gets an array of parameter descriptions for all this procedure's parameters
INVALID_PATH - Static variable in interface com.rabbitmq.client.AMQP
invoke(Object, Method, Object[]) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Public API - implements InvocationHandler.invoke.
isAllowedToModifyThreads() - Static method in class com.rabbitmq.client.impl.Environment: Deprecated.
isApproachingExpiration(Duration) - Method in interface com.rabbitmq.client.impl.CredentialsRefreshService: Provide a hint about whether credentials should be renewed now or not before attempting to connect.
isApproachingExpiration(Duration) - Method in class com.rabbitmq.client.impl.DefaultCredentialsRefreshService
isAutoDelete() - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
isAutoDelete() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
isAutomaticRecoveryEnabled() - Method in class com.rabbitmq.client.ConnectionFactory: Returns true if automatic connection recovery is enabled, false otherwise
isChannelShouldCheckRpcResponseType() - Method in class com.rabbitmq.client.ConnectionFactory
isDurable() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
isEmpty() - Method in class com.rabbitmq.client.impl.nio.BlockingQueueNioQueue
isEmpty() - Method in interface com.rabbitmq.client.impl.nio.NioQueue: Returns true if the queue contains no element.
isEmpty() - Method in class com.rabbitmq.client.impl.SetQueue
isExclusive() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
isHardError() - Method in exception com.rabbitmq.client.ShutdownSignalException
isHostWithPort(String) - Static method in class com.rabbitmq.client.Address
isIdempotent() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
isInitiatedByApplication() - Method in exception com.rabbitmq.client.ShutdownSignalException
isOpen() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
isOpen() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
isOpen() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
isOpen() - Method in interface com.rabbitmq.client.ShutdownNotifier: Determine whether the component is currently open.
isOutstandingRpc() - Method in class com.rabbitmq.client.impl.AMQChannel
isRedeliver() - Method in class com.rabbitmq.client.Envelope: Get the redelivery flag included in this parameter envelope.
isResponseCompatibleWithRequest(Method, Method) - Static method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
isRunning() - Method in class com.rabbitmq.client.impl.AMQConnection
isServerNamed() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
isSSL() - Method in class com.rabbitmq.client.ConnectionFactory
isSystem() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
isSystemDescribe() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
isTopologyRecoveryEnabled() - Method in class com.rabbitmq.client.ConnectionFactory: Returns true if topology recovery is enabled, false otherwise
isTopologyRecoveryEnabled() - Method in class com.rabbitmq.client.impl.ConnectionParams
isUnderflowHandlingEnabled() - Method in class com.rabbitmq.client.impl.nio.FrameBuilder
isUnderflowHandlingEnabled() - Method in class com.rabbitmq.client.impl.nio.SslEngineFrameBuilder
iterator() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Returns an iterator over the elements in this queue in proper sequence.

J

JacksonJsonRpcMapper - Class in com.rabbitmq.tools.jsonrpc: JsonRpcMapper based on Jackson.
JacksonJsonRpcMapper() - Constructor for class com.rabbitmq.tools.jsonrpc.JacksonJsonRpcMapper
JacksonJsonRpcMapper(ObjectMapper) - Constructor for class com.rabbitmq.tools.jsonrpc.JacksonJsonRpcMapper
JDKSaslConfig - Class in com.rabbitmq.client: Implementation of SaslConfig that uses the JDK SASL implementation.
JDKSaslConfig(ConnectionFactory) - Constructor for class com.rabbitmq.client.JDKSaslConfig: Create a JDKSaslConfig which only wants to use PLAIN.
JDKSaslConfig(ConnectionFactory, String[]) - Constructor for class com.rabbitmq.client.JDKSaslConfig: Create a JDKSaslConfig with a list of mechanisms to use.
JSON_RPC_VERSION - Static variable in class com.rabbitmq.tools.jsonrpc.ServiceDescription
JSONReader - Class in com.rabbitmq.tools.json: Deprecated.
Use a third-party JSON library, e.g. Jackson or Gson
JSONReader() - Constructor for class com.rabbitmq.tools.json.JSONReader: Deprecated.
JsonRpcClient - Class in com.rabbitmq.tools.jsonrpc: JSON-RPC is a lightweight RPC mechanism using JSON as a data language for request and reply messages.
JsonRpcClient(Channel, String, String) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcClient
JsonRpcClient(Channel, String, String, int) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Construct a new JsonRpcClient, passing the parameters through to RpcClient's constructor.
JsonRpcClient(Channel, String, String, int, JsonRpcMapper) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Construct a new JsonRpcClient, passing the parameters through to RpcClient's constructor.
JsonRpcClient(RpcClientParams, JsonRpcMapper) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Construct a new JsonRpcClient, passing the RpcClientParams through RpcClient's constructor.
JsonRpcException - Exception in com.rabbitmq.tools.jsonrpc: Thrown when a JSON-RPC service indicates an error occurred during a call.
JsonRpcException() - Constructor for exception com.rabbitmq.tools.jsonrpc.JsonRpcException
JsonRpcException(String, String, int, String, Object) - Constructor for exception com.rabbitmq.tools.jsonrpc.JsonRpcException
JsonRpcMapper - Interface in com.rabbitmq.tools.jsonrpc: Abstraction to handle JSON parsing and generation.
JsonRpcMapper.JsonRpcRequest - Class in com.rabbitmq.tools.jsonrpc
JsonRpcMapper.JsonRpcResponse - Class in com.rabbitmq.tools.jsonrpc
JsonRpcMappingException - Exception in com.rabbitmq.tools.jsonrpc
JsonRpcMappingException(String, Throwable) - Constructor for exception com.rabbitmq.tools.jsonrpc.JsonRpcMappingException
JsonRpcRequest(Object, String, String, Object[]) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcRequest
JsonRpcResponse(Object, Object, JsonRpcException) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcMapper.JsonRpcResponse
JsonRpcServer - Class in com.rabbitmq.tools.jsonrpc: JSON-RPC Server class.
JsonRpcServer(Channel, Class<?>, Object) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Construct a server that talks to the outside world using the given channel, and constructs a fresh temporary queue.
JsonRpcServer(Channel, Class<?>, Object, JsonRpcMapper) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcServer
JsonRpcServer(Channel, String, Class<?>, Object) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Construct a server that talks to the outside world using the given channel and queue name.
JsonRpcServer(Channel, String, Class<?>, Object, JsonRpcMapper) - Constructor for class com.rabbitmq.tools.jsonrpc.JsonRpcServer
JSONSerializable - Interface in com.rabbitmq.tools.json: Deprecated.
Use a third-party JSON library, e.g. Jackson or Gson
jsonSerialize(JSONWriter) - Method in interface com.rabbitmq.tools.json.JSONSerializable: Deprecated.

Called during serialization to JSON.
JSONUtil - Class in com.rabbitmq.tools.json: Utility methods for working with JSON objects in Java.
JSONUtil() - Constructor for class com.rabbitmq.tools.json.JSONUtil
JSONWriter - Class in com.rabbitmq.tools.json: Deprecated.
Use a third-party JSON library, e.g. Jackson or Gson
JSONWriter() - Constructor for class com.rabbitmq.tools.json.JSONWriter: Deprecated.
JSONWriter(boolean) - Constructor for class com.rabbitmq.tools.json.JSONWriter: Deprecated.

K

knownHosts(String) - Method in class com.rabbitmq.client.AMQP.Connection.OpenOk.Builder

L

length() - Method in interface com.rabbitmq.client.LongString
limit(K) - Method in class com.rabbitmq.client.impl.WorkPool
ListAddressResolver - Class in com.rabbitmq.client: Simple implementation of AddressResolver that returns a fixed list.
ListAddressResolver(List<Address>) - Constructor for class com.rabbitmq.client.ListAddressResolver
load(ConnectionFactory, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
load(ConnectionFactory, String, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
load(ConnectionFactory, Map<String, String>) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
load(ConnectionFactory, Map<String, String>, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
load(ConnectionFactory, Properties) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
load(ConnectionFactory, Properties, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
load(String) - Method in class com.rabbitmq.client.ConnectionFactory: Load settings from a property file.
load(String, String) - Method in class com.rabbitmq.client.ConnectionFactory: Load settings from a property file.
load(Map<String, String>) - Method in class com.rabbitmq.client.ConnectionFactory: Load settings from a Map instance.
load(Map<String, String>, String) - Method in class com.rabbitmq.client.ConnectionFactory: Load settings from a Map instance.
load(Properties) - Method in class com.rabbitmq.client.ConnectionFactory: Load settings from a Properties instance.
load(Properties, String) - Method in class com.rabbitmq.client.ConnectionFactory: Load settings from a Properties instance.
locale(String) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
locales(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
locales(String) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
log(RecordedEntity, Exception, int) - Method in class com.rabbitmq.client.impl.recovery.DefaultRetryHandler
log(String, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
logPeerCertificateInfo(SSLSession) - Static method in class com.rabbitmq.client.impl.TlsUtils: Log details on peer certificate and certification chain.
LogTrafficListener - Class in com.rabbitmq.client.impl: TrafficListener that logs Command at TRACE level.
LogTrafficListener() - Constructor for class com.rabbitmq.client.impl.LogTrafficListener
LongString - Interface in com.rabbitmq.client: An object providing access to a LongString.
LongStringHelper - Class in com.rabbitmq.client.impl: Utility for working with LongStrings.
LongStringHelper() - Constructor for class com.rabbitmq.client.impl.LongStringHelper
lookup(Class<?>) - Static method in class com.rabbitmq.tools.jsonrpc.ParameterDescription
lookUp(String, Map<String, String>, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
lookUp(String, Map<String, String>, String, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
lookupSrvRecords(String, String) - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver

M

mainloop() - Method in class com.rabbitmq.client.RpcServer: Public API - main server loop.
MAJOR - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
makeException(E) - Static method in class com.rabbitmq.utility.ValueOrException: Factory method for exceptions
makeStackTrace(Throwable) - Static method in class com.rabbitmq.utility.Utility: Deprecated.
use logging library instead for logging stack traces somewhere
makeValue(V) - Static method in class com.rabbitmq.utility.ValueOrException: Factory method for values
MalformedFrameException - Exception in com.rabbitmq.client: Encapsulates a frame format error at the wire level.
MalformedFrameException(String) - Constructor for exception com.rabbitmq.client.MalformedFrameException: Instantiate a MalformedFrameException.
mandatory() - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
mandatory(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
mapCall(Object[]) - Method in class com.rabbitmq.client.RpcClient: Perform an AMQP wire-protocol-table based RPC roundtrip, first constructing the table from an array of alternating keys (in even-numbered elements, starting at zero) and values (in odd-numbered elements, starting at one)
Restrictions on value arguments apply as in RpcClient.mapCall(Map).
mapCall(Map<String, Object>) - Method in class com.rabbitmq.client.RpcClient: Perform an AMQP wire-protocol-table based RPC roundtrip

There are some restrictions on the values appearing in the table:
they must be of type String, LongString, Integer, BigDecimal, Date, or (recursively) a Map of the enclosing type.
MapRpcServer - Class in com.rabbitmq.client: Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies.
MapRpcServer(Channel) - Constructor for class com.rabbitmq.client.MapRpcServer
MapRpcServer(Channel, String) - Constructor for class com.rabbitmq.client.MapRpcServer
mapSrvRecord(String) - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver
mark(int) - Method in class com.rabbitmq.client.impl.TruncatedInputStream
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of an acknowledged message.
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markConsumedMessage() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a consumed message.
markConsumedMessage() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markConsumedMessage() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markConsumedMessage() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markMessagePublishAcknowledged() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a message publishing acknowledgement.
markMessagePublishAcknowledged() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markMessagePublishAcknowledged() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markMessagePublishAcknowledged() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markMessagePublishFailed() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a message publishing failure.
markMessagePublishFailed() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markMessagePublishFailed() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markMessagePublishFailed() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markMessagePublishNotAcknowledged() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a message publishing not being acknowledged.
markMessagePublishNotAcknowledged() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markMessagePublishNotAcknowledged() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markMessagePublishNotAcknowledged() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markPublishedMessage() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a published message.
markPublishedMessage() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markPublishedMessage() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markPublishedMessage() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markPublishedMessageUnrouted() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a published message not being routed.
markPublishedMessageUnrouted() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markPublishedMessageUnrouted() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markPublishedMessageUnrouted() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markRejectedMessage() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector: Marks the event of a rejected message.
markRejectedMessage() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
markRejectedMessage() - Method in class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
markRejectedMessage() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
markRpcFinished() - Method in class com.rabbitmq.client.impl.AMQChannel
markRpcFinished() - Method in class com.rabbitmq.client.impl.ChannelN
matchingMethod(String, Object[]) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Retrieves the best matching method for the given method name and parameters.
MAX_LENGTH - Static variable in interface com.rabbitmq.client.LongString
maybeShuffle(List<Address>) - Method in interface com.rabbitmq.client.AddressResolver: Optionally shuffle the list of addresses returned by AddressResolver.getAddresses().
mechanism(String) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
mechanisms(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
mechanisms(String) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeleteOk.Builder
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.PurgeOk.Builder
messageCount(String) - Method in interface com.rabbitmq.client.Channel: Returns the number of messages in a queue ready to be delivered to consumers.
messageCount(String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Returns the number of messages in a queue ready to be delivered to consumers.
messageCount(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
messageId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
MessageProperties - Class in com.rabbitmq.client: Constant holder class with useful static instances of AMQContentHeader.
MessageProperties() - Constructor for class com.rabbitmq.client.MessageProperties
Method - Class in com.rabbitmq.client.impl: Base class for AMQP method objects, specialized by autogenerated code in AMQP.java.
Method - Interface in com.rabbitmq.client: Public interface to objects representing an AMQP 0-9-1 method
Method() - Constructor for class com.rabbitmq.client.impl.Method
MethodArgumentReader - Class in com.rabbitmq.client.impl: Parses AMQP wire-protocol Method arguments from a DataInputStream.
MethodArgumentReader(ValueReader) - Constructor for class com.rabbitmq.client.impl.MethodArgumentReader: Construct a MethodArgumentReader from the given ValueReader.
MethodArgumentWriter - Class in com.rabbitmq.client.impl: Generates AMQP wire-protocol encoded arguments.
MethodArgumentWriter(ValueWriter) - Constructor for class com.rabbitmq.client.impl.MethodArgumentWriter: Constructs a MethodArgumentWriter targeting the given DataOutputStream.
methodId - Variable in exception com.rabbitmq.client.UnknownClassOrMethodId
methodId(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
methodId(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
metricsCollector - Variable in class com.rabbitmq.client.impl.AMQConnection
metricsCollector - Variable in class com.rabbitmq.client.impl.ChannelManager
metricsCollector - Variable in class com.rabbitmq.client.impl.ChannelN
MetricsCollector - Interface in com.rabbitmq.client: Interface to gather execution data of the client.
MicrometerMetricsCollector - Class in com.rabbitmq.client.impl: Micrometer implementation of MetricsCollector.
MicrometerMetricsCollector(MeterRegistry) - Constructor for class com.rabbitmq.client.impl.MicrometerMetricsCollector
MicrometerMetricsCollector(MeterRegistry, String) - Constructor for class com.rabbitmq.client.impl.MicrometerMetricsCollector
MicrometerMetricsCollector(MeterRegistry, String, Iterable<Tag>) - Constructor for class com.rabbitmq.client.impl.MicrometerMetricsCollector
MicrometerMetricsCollector(MeterRegistry, String, String...) - Constructor for class com.rabbitmq.client.impl.MicrometerMetricsCollector
MicrometerMetricsCollector(Function<MicrometerMetricsCollector.Metrics, Object>) - Constructor for class com.rabbitmq.client.impl.MicrometerMetricsCollector
MicrometerMetricsCollector.Metrics - Enum in com.rabbitmq.client.impl
MINIMAL_BASIC - Static variable in class com.rabbitmq.client.MessageProperties: Empty basic properties, with no fields set
MINIMAL_PERSISTENT_BASIC - Static variable in class com.rabbitmq.client.MessageProperties: Empty basic properties, with only deliveryMode set to 2 (persistent)
MINOR - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
MissedHeartbeatException - Exception in com.rabbitmq.client: Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down.
MissedHeartbeatException(String) - Constructor for exception com.rabbitmq.client.MissedHeartbeatException
multiple() - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
multiple() - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
multiple(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
multiple(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder

N

Nack(long, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
Nack(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
NACKED_PUBLISHED_MESSAGES - Enum constant in enum com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
name - Variable in class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
needToDispatchIoError(SocketChannelFrameHandlerState) - Method in class com.rabbitmq.client.impl.nio.NioLoop
negotiateChannelMax(int, int) - Method in class com.rabbitmq.client.impl.AMQConnection: Private API, allows for easier simulation of bogus clients.
NetworkConnection - Interface in com.rabbitmq.client.impl
newChannel(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
newChannel(Channel) - Method in interface com.rabbitmq.client.MetricsCollector
newChannel(Channel) - Method in class com.rabbitmq.client.NoOpMetricsCollector
newConnection() - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection.
newConnection() - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
newConnection(Address[]) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection, picking the first available address from the list.
newConnection(Address[], String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection with a client-provided name, picking the first available address from the list.
newConnection(AddressResolver) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection, picking the first available address from the list provided by the AddressResolver.
newConnection(Connection) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
newConnection(Connection) - Method in interface com.rabbitmq.client.MetricsCollector
newConnection(Connection) - Method in class com.rabbitmq.client.NoOpMetricsCollector
newConnection(String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection.
newConnection(ExecutorService) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection.
newConnection(ExecutorService, Address[]) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection, picking the first available address from the list.
newConnection(ExecutorService, Address[], String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection with a client-provided name, picking the first available address from the list.
newConnection(ExecutorService, AddressResolver) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection, picking the first available address from the list provided by the AddressResolver.
newConnection(ExecutorService, AddressResolver, String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection with a client-provided name, picking the first available address from the list provided by the AddressResolver.
newConnection(ExecutorService, String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection.
newConnection(ExecutorService, List<Address>) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection, picking the first available address from the list.
newConnection(ExecutorService, List<Address>, String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection with a client-provided name, picking the first available address from the list.
newConnection(List<Address>) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection, picking the first available address from the list.
newConnection(List<Address>, String) - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection with a client-provided name, picking the first available address from the list.
newSecret(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.UpdateSecret.Builder
newSecret(String) - Method in class com.rabbitmq.client.AMQP.Connection.UpdateSecret.Builder
newThread(ThreadFactory, Runnable, String) - Static method in class com.rabbitmq.client.impl.Environment
newThread(ThreadFactory, Runnable, String, boolean) - Static method in class com.rabbitmq.client.impl.Environment
nextDelivery() - Method in interface com.rabbitmq.client.RpcServer.RpcConsumer
nextOutstandingRpc() - Method in class com.rabbitmq.client.impl.AMQChannel
nextWorkBlock(Collection<W>, int) - Method in class com.rabbitmq.client.impl.WorkPool: Return the next ready client, and transfer a collection of that client's items to process.
NIO_NB_IO_THREADS - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
NIO_READ_BYTE_BUFFER_SIZE - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
NIO_WRITE_BYTE_BUFFER_SIZE - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
NIO_WRITE_ENQUEUING_TIMEOUT_IN_MS - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
NIO_WRITE_QUEUE_CAPACITY - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
NioContext - Class in com.rabbitmq.client.impl.nio: Context when creating resources for a NIO-based connection.
NioHelper - Class in com.rabbitmq.client.impl.nio
NioHelper() - Constructor for class com.rabbitmq.client.impl.nio.NioHelper
NioLoop - Class in com.rabbitmq.client.impl.nio: Logic of the NIO loop.
NioLoop(NioParams, NioLoopContext) - Constructor for class com.rabbitmq.client.impl.nio.NioLoop
NioLoopContext - Class in com.rabbitmq.client.impl.nio
NioLoopContext(SocketChannelFrameHandlerFactory, NioParams) - Constructor for class com.rabbitmq.client.impl.nio.NioLoopContext
NioParams - Class in com.rabbitmq.client.impl.nio: Parameters used to configure the NIO mode of a ConnectionFactory.
NioParams() - Constructor for class com.rabbitmq.client.impl.nio.NioParams
NioParams(NioParams) - Constructor for class com.rabbitmq.client.impl.nio.NioParams
NioQueue - Interface in com.rabbitmq.client.impl.nio: Contract to exchange frame between application threads and NIO thread.
NO_CONSUMERS - Static variable in interface com.rabbitmq.client.AMQP
NO_OP - Static variable in interface com.rabbitmq.client.TrafficListener: No-op TrafficListener.
NO_ROUTE - Static variable in interface com.rabbitmq.client.AMQP
NO_RPC_TIMEOUT - Static variable in class com.rabbitmq.client.impl.AMQChannel
NO_TIMEOUT - Static variable in class com.rabbitmq.client.RpcClient: NO_TIMEOUT value must match convention on BlockingCell.uninterruptibleGet(int)
noAck() - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
noAck() - Method in class com.rabbitmq.client.AMQP.Basic.Get.Builder
noAck(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
noAck(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Get.Builder
noLocal() - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
noLocal(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
NoOpMetricsCollector - Class in com.rabbitmq.client
NoOpMetricsCollector() - Constructor for class com.rabbitmq.client.NoOpMetricsCollector
NOT_ALLOWED - Static variable in interface com.rabbitmq.client.AMQP
NOT_FOUND - Static variable in interface com.rabbitmq.client.AMQP
NOT_IMPLEMENTED - Static variable in interface com.rabbitmq.client.AMQP
notifyListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
notifyListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
notifyListeners() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
notifyListeners() - Method in interface com.rabbitmq.client.ShutdownNotifier: Protected API - notify the listeners attached to the component
notifyOutstandingRpc(ShutdownSignalException) - Method in class com.rabbitmq.client.impl.AMQChannel
nowait() - Method in class com.rabbitmq.client.AMQP.Basic.Cancel.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Confirm.Select.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
nowait() - Method in class com.rabbitmq.client.AMQP.Queue.Purge.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Cancel.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Confirm.Select.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
nowait(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Purge.Builder

O

OAuth2ClientCredentialsGrantCredentialsProvider - Class in com.rabbitmq.client.impl: A CredentialsProvider that performs an OAuth 2 Client Credentials flow to retrieve a token.
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider: Use OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder to create an instance.
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider: Use OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder to create an instance.
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>, Consumer<HttpURLConnection>) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider: Use OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder to create an instance.
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>, HostnameVerifier, SSLSocketFactory) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider: Use OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder to create an instance.
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>, HostnameVerifier, SSLSocketFactory, Consumer<HttpURLConnection>) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider: Use OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder to create an instance.
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, HostnameVerifier, SSLSocketFactory) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider: Use OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder to create an instance.
OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder - Class in com.rabbitmq.client.impl: Helper to create OAuth2ClientCredentialsGrantCredentialsProvider instances.
OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration - Class in com.rabbitmq.client.impl: TLS configuration for a OAuth2ClientCredentialsGrantCredentialsProvider.
OAuth2ClientCredentialsGrantCredentialsProvider.Token - Class in com.rabbitmq.client.impl
OAuth2ClientCredentialsGrantCredentialsProviderBuilder() - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder
OAuthTokenManagementException - Exception in com.rabbitmq.client.impl
OAuthTokenManagementException(String) - Constructor for exception com.rabbitmq.client.impl.OAuthTokenManagementException
OAuthTokenManagementException(String, Throwable) - Constructor for exception com.rabbitmq.client.impl.OAuthTokenManagementException
offer(WriteRequest) - Method in class com.rabbitmq.client.impl.nio.BlockingQueueNioQueue
offer(WriteRequest) - Method in interface com.rabbitmq.client.impl.nio.NioQueue: Enqueue a frame, block if the queue is full.
offer(E) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Inserts the specified element at the tail of this queue if possible, returning immediately if this queue is full.
offer(E, long, TimeUnit) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Inserts the specified element at the tail of this queue, waiting if necessary up to the specified wait time for space to become available.
open() - Method in class com.rabbitmq.client.impl.ChannelN: Package method: open the channel.
Open(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Open
Open(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Open
Open(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Open
Open(String, String, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Open
openChannel() - Method in interface com.rabbitmq.client.Connection: Create a new channel wrapped in an Optional.
openChannel(int) - Method in interface com.rabbitmq.client.Connection: Create a new channel, using the specified channel number if possible.
OpenOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
OpenOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
OpenOk(LongString) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
OpenOk(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
OpenTelemetryMetricsCollector - Class in com.rabbitmq.client.impl: OpenTelemetry implementation of MetricsCollector.
OpenTelemetryMetricsCollector(OpenTelemetry) - Constructor for class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
OpenTelemetryMetricsCollector(OpenTelemetry, String) - Constructor for class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
OpenTelemetryMetricsCollector(OpenTelemetry, String, Attributes) - Constructor for class com.rabbitmq.client.impl.OpenTelemetryMetricsCollector
outOfBand(String) - Method in class com.rabbitmq.client.AMQP.Channel.Open.Builder

P

parameter(String, String) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder: Extra parameters to pass in the request.
ParameterDescription - Class in com.rabbitmq.tools.jsonrpc: Description of a single JSON-RPC procedure parameter.
ParameterDescription() - Constructor for class com.rabbitmq.tools.jsonrpc.ParameterDescription
ParameterDescription(int, Class<?>) - Constructor for class com.rabbitmq.tools.jsonrpc.ParameterDescription
ParameterDescription(Map<String, Object>) - Constructor for class com.rabbitmq.tools.jsonrpc.ParameterDescription
params(ExecutorService) - Method in class com.rabbitmq.client.ConnectionFactory
parse(String, ServiceDescription) - Method in class com.rabbitmq.tools.jsonrpc.DefaultJsonRpcMapper: Deprecated.
parse(String, ServiceDescription) - Method in class com.rabbitmq.tools.jsonrpc.JacksonJsonRpcMapper
parse(String, ServiceDescription) - Method in interface com.rabbitmq.tools.jsonrpc.JsonRpcMapper: Parses a JSON RPC request.
parse(String, Class<?>) - Method in class com.rabbitmq.tools.jsonrpc.DefaultJsonRpcMapper: Deprecated.
parse(String, Class<?>) - Method in class com.rabbitmq.tools.jsonrpc.JacksonJsonRpcMapper
parse(String, Class<?>) - Method in interface com.rabbitmq.tools.jsonrpc.JsonRpcMapper: Parses a JSON RPC response.
parseAddress(String) - Static method in class com.rabbitmq.client.Address: Factory method: takes a formatted addressString string as construction parameter
parseAddresses(String) - Static method in class com.rabbitmq.client.Address: Array-based factory method: takes an array of formatted address strings as construction parameter
parseHost(String) - Static method in class com.rabbitmq.client.Address: Extracts hostname or IP address from a string containing a hostname, IP address, hostname:port pair or IP address:port pair.
parsePort(String) - Static method in class com.rabbitmq.client.Address
parseToken(String) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
passive() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
passive() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
passive() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
passive(boolean) - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
passive(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
passive(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
PASSWORD - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
passwordFromToken(OAuth2ClientCredentialsGrantCredentialsProvider.Token) - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
passwordFromToken(T) - Method in class com.rabbitmq.client.impl.RefreshProtectedCredentialsProvider
peek() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
peerCertificateInfo(Certificate, String) - Static method in class com.rabbitmq.client.impl.TlsUtils: Get a string representation of certificate info.
PERSISTENT_BASIC - Static variable in class com.rabbitmq.client.MessageProperties: Content-type "application/octet-stream", deliveryMode 2 (persistent), priority zero
PERSISTENT_TEXT_PLAIN - Static variable in class com.rabbitmq.client.MessageProperties: Content-type "text/plain", deliveryMode 2 (persistent), priority zero
PLAIN - Static variable in class com.rabbitmq.client.DefaultSaslConfig
PlainMechanism - Class in com.rabbitmq.client.impl: The PLAIN auth mechanism
PlainMechanism() - Constructor for class com.rabbitmq.client.impl.PlainMechanism
poll() - Method in class com.rabbitmq.client.impl.nio.BlockingQueueNioQueue
poll() - Method in interface com.rabbitmq.client.impl.nio.NioQueue: Retrieves and removes the head of this queue, or returns null if this queue is empty.
poll() - Method in class com.rabbitmq.client.impl.SetQueue: Remove the head of the queue and return it.
poll() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
poll(long, TimeUnit) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
PORT - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
PORT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
portOrDefault(int, boolean) - Static method in class com.rabbitmq.client.ConnectionFactory
PossibleAuthenticationFailureException - Exception in com.rabbitmq.client: Thrown when the likely cause is an authentication failure.
PossibleAuthenticationFailureException(String) - Constructor for exception com.rabbitmq.client.PossibleAuthenticationFailureException
PossibleAuthenticationFailureException(Throwable) - Constructor for exception com.rabbitmq.client.PossibleAuthenticationFailureException
postprocessReplyProperties(Delivery, AMQP.BasicProperties.Builder) - Method in class com.rabbitmq.client.RpcServer: Gives a chance to set/modify reply properties after the handling call
PRECONDITION_FAILED - Static variable in interface com.rabbitmq.client.AMQP
prefetchCount(int) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
prefetchSize(int) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
preprocessReplyProperties(Delivery, AMQP.BasicProperties.Builder) - Method in class com.rabbitmq.client.RpcServer: Gives a chance to set/modify reply properties before handling call.
primitiveCall(byte[]) - Method in class com.rabbitmq.client.RpcClient: Perform a simple byte-array-based RPC roundtrip.
primitiveCall(AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.RpcClient
primitiveCall(AMQP.BasicProperties, byte[], int) - Method in class com.rabbitmq.client.RpcClient
priority(Integer) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
ProcedureDescription - Class in com.rabbitmq.tools.jsonrpc: Description of a single JSON-RPC procedure.
ProcedureDescription() - Constructor for class com.rabbitmq.tools.jsonrpc.ProcedureDescription
ProcedureDescription(Method) - Constructor for class com.rabbitmq.tools.jsonrpc.ProcedureDescription
ProcedureDescription(Map<String, Object>) - Constructor for class com.rabbitmq.tools.jsonrpc.ProcedureDescription
processAsync(Command) - Method in class com.rabbitmq.client.impl.AMQChannel: Protected API - called by nextCommand to check possibly handle an incoming Command before it is returned to the caller of nextCommand.
processAsync(Command) - Method in class com.rabbitmq.client.impl.ChannelN: Protected API - Filters the inbound command stream, processing Basic.Deliver, Basic.Return and Channel.Close specially.
processControlCommand(Command) - Method in class com.rabbitmq.client.impl.AMQConnection: Handles incoming control commands on channel zero.
processDelivery(Command, AMQImpl.Basic.Deliver) - Method in class com.rabbitmq.client.impl.ChannelN
processDelivery(Command, AMQImpl.Basic.Deliver) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
processRequest(Delivery) - Method in class com.rabbitmq.client.RpcServer: Private API - Process a single request.
processShutdownSignal(ShutdownSignalException, boolean, boolean) - Method in class com.rabbitmq.client.impl.AMQChannel: Protected API - respond, in the driver thread, to a ShutdownSignalException.
processShutdownSignal(ShutdownSignalException, boolean, boolean) - Method in class com.rabbitmq.client.impl.ChannelN: Protected API - overridden to quiesce consumer work and broadcast the signal to all consumers after calling the superclass's method.
processUriQueryParameter(String, String) - Method in class com.rabbitmq.client.ConnectionFactory: Hook to process query parameters not handled natively.
properties - Variable in class com.rabbitmq.client.RpcClient.Response
PROTOCOL() - Constructor for class com.rabbitmq.client.AMQP.PROTOCOL
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecretOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
protocolClassId() - Method in class com.rabbitmq.client.impl.Method: Retrieve the protocol class ID
protocolClassId() - Method in interface com.rabbitmq.client.Method: Retrieve the protocol class ID
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecret
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.UpdateSecretOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
protocolMethodId() - Method in class com.rabbitmq.client.impl.