Index

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, int) - 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
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
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
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 Class in com.rabbitmq.client
Thrown when application tries to perform an action on connection/channel which was already closed
AlreadyClosedException(ShutdownSignalException) - Constructor for exception class com.rabbitmq.client.AlreadyClosedException
 
AlreadyClosedException(ShutdownSignalException, Throwable) - Constructor for exception class 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.
AMQCommand(Method, AMQContentHeader, byte[], int) - 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, ObservationCollector) - 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 Class in com.rabbitmq.client
Thrown when the broker refuses access due to an authentication failure.
AuthenticationFailureException(String) - Constructor for exception class 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, ObservationCollector) - 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
 
basicConsume(String, String, Consumer) - Method in interface com.rabbitmq.client.observation.ObservationCollector
Decorate consumer registration.
basicGet(ObservationCollector.BasicGetCall, String) - Method in interface com.rabbitmq.client.observation.ObservationCollector
Decorate message polling with basic.get.
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> - 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
build() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder
build() - Method in class com.rabbitmq.client.impl.recovery.TopologyRecoveryRetryHandlerBuilder
 
build() - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Create the Micrometer ObservationCollector.
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 Class 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 class 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, ObservationCollector) - 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, ObservationCollector) - 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.
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 class 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.client.observation - package com.rabbitmq.client.observation
 
com.rabbitmq.client.observation.micrometer - package com.rabbitmq.client.observation.micrometer
 
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
 
Concurrency - Search tag in class com.rabbitmq.client.impl.AMQCommand
Section
Concurrency - Search tag in interface com.rabbitmq.client.impl.FrameHandler
Section
Concurrency Considerations - Search tag in interface com.rabbitmq.client.Channel
Section
Concurrency Semantics: - Search tag in class com.rabbitmq.utility.IntAllocator
Section
Concurrent Semantics - Search tag in class com.rabbitmq.client.impl.SetQueue
Section
Concurrent Semantics - Search tag in class com.rabbitmq.client.impl.WorkPool
Section
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
 
connectionInfo() - Method in class com.rabbitmq.client.impl.AMQChannel
 
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 Class in com.rabbitmq.client
 
ConsumerCancelledException() - Constructor for exception class 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.
customProcessObservationConvention(DeliverObservationConvention) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Custom convention for basic.deliver.
customPublishObservationConvention(PublishObservationConvention) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Custom convention for basic.publish.
customReceiveObservationConvention(DeliverObservationConvention) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Custom convention for basic.get.

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
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.
DefaultJsonRpcMapper() - Constructor for class com.rabbitmq.tools.jsonrpc.DefaultJsonRpcMapper
Deprecated.
 
DefaultMethodVisitor() - Constructor for class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
 
defaultProcessObservationConvention(DeliverObservationConvention) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Default convention for basic.delivery.
DefaultProcessObservationConvention - Class in com.rabbitmq.client.observation.micrometer
 
DefaultProcessObservationConvention(String) - Constructor for class com.rabbitmq.client.observation.micrometer.DefaultProcessObservationConvention
 
defaultPublishObservationConvention(PublishObservationConvention) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Default convention for basic.publish.
DefaultPublishObservationConvention - Class in com.rabbitmq.client.observation.micrometer
Default implementation of PublishObservationConvention.
DefaultPublishObservationConvention() - Constructor for class com.rabbitmq.client.observation.micrometer.DefaultPublishObservationConvention
 
DefaultPublishObservationConvention(String) - Constructor for class com.rabbitmq.client.observation.micrometer.DefaultPublishObservationConvention
 
defaultReceiveObservationConvention(DeliverObservationConvention) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Default convention for basic.get.
DefaultReceiveObservationConvention - Class in com.rabbitmq.client.observation.micrometer
 
DefaultReceiveObservationConvention(String) - Constructor for class com.rabbitmq.client.observation.micrometer.DefaultReceiveObservationConvention
 
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.
DeliverContext - Class in com.rabbitmq.client.observation.micrometer
Observation.Context for use with RabbitMQ client Observation instrumentation.
DeliverObservationConvention - Interface in com.rabbitmq.client.observation.micrometer
ObservationConvention for RabbitMQ client instrumentation.
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, int) - 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 interface com.rabbitmq.client.observation.ObservationCollector.BasicGetCall
 
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 class 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 class 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 class com.rabbitmq.client.ProtocolVersionMismatchException
The client's AMQP specification major version.
getClientMinor() - Method in exception class 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 class 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 class 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
 
getConnectionInfo() - Method in class com.rabbitmq.client.observation.micrometer.PublishContext
 
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.
getContextualName(DeliverContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultProcessObservationConvention
 
getContextualName(DeliverContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultReceiveObservationConvention
 
getContextualName(PublishContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultPublishObservationConvention
 
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 class 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.observation.micrometer.DeliverContext
 
getExchange() - Method in class com.rabbitmq.client.observation.micrometer.PublishContext
 
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 class 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
 
getHighCardinalityKeyValues(DeliverContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultProcessObservationConvention
 
getHighCardinalityKeyValues(DeliverContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultReceiveObservationConvention
 
getHighCardinalityKeyValues(PublishContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultPublishObservationConvention
 
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
 
getLowCardinalityKeyValues(DeliverContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultProcessObservationConvention
 
getLowCardinalityKeyValues(DeliverContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultReceiveObservationConvention
 
getLowCardinalityKeyValues(PublishContext) - Method in class com.rabbitmq.client.observation.micrometer.DefaultPublishObservationConvention
 
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
 
getMaxInboundMessageBodySize() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
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 class 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 class 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 class 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 class com.rabbitmq.client.observation.micrometer.DefaultProcessObservationConvention
 
getName() - Method in class com.rabbitmq.client.observation.micrometer.DefaultPublishObservationConvention
 
getName() - Method in class com.rabbitmq.client.observation.micrometer.DefaultReceiveObservationConvention
 
getName() - Method in interface com.rabbitmq.client.SaslMechanism
The name of this mechanism (e.g.
getName() - Method in exception class 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
getPayloadSizeBytes() - Method in class com.rabbitmq.client.observation.micrometer.DeliverContext
 
getPayloadSizeBytes() - Method in class com.rabbitmq.client.observation.micrometer.PublishContext
 
getPeerAddress() - Method in interface com.rabbitmq.client.observation.ObservationCollector.ConnectionInfo
 
getPeerPort() - Method in interface com.rabbitmq.client.observation.ObservationCollector.ConnectionInfo
 
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
 
getQueue() - Method in class com.rabbitmq.client.observation.micrometer.DeliverContext
 
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 class com.rabbitmq.client.ShutdownSignalException
 
getReceivedAt() - Method in class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.Token
 
getReceivedFrame() - Method in exception class 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 class 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 class 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 class 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.observation.micrometer.DeliverContext
 
getRoutingKey() - Method in class com.rabbitmq.client.observation.micrometer.PublishContext
 
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 class com.rabbitmq.client.UnexpectedFrameError
 
getServerMajor() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException
The server's AMQP specification major version.
getServerMinor() - Method in exception class 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 class 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
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
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
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
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
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
 
Implementation notes: - Search tag in class com.rabbitmq.utility.IntAllocator
Section
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.
ioLoopThread(Thread) - Method in class com.rabbitmq.client.impl.AMQConnection
 
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 class 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 class 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 Class in com.rabbitmq.tools.jsonrpc
Thrown when a JSON-RPC service indicates an error occurred during a call.
JsonRpcException() - Constructor for exception class com.rabbitmq.tools.jsonrpc.JsonRpcException
 
JsonRpcException(String, String, int, String, Object) - Constructor for exception class 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 Class in com.rabbitmq.tools.jsonrpc
 
JsonRpcMappingException(String, Throwable) - Constructor for exception class 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

keepObservationStartedOnBasicGet(boolean) - Method in class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
Whether to keep the basic.get observation started or not.
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 Class in com.rabbitmq.client
Encapsulates a frame format error at the wire level.
MalformedFrameException(String) - Constructor for exception class 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
 
maxInboundMessageBodySize - Variable in class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
 
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
 
MESSAGING_DESTINATION_NAME - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.HighCardinalityTags
The message destination name.
MESSAGING_MESSAGE_PAYLOAD_SIZE_BYTES - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.HighCardinalityTags
 
MESSAGING_OPERATION - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.LowCardinalityTags
A string identifying the kind of messaging operation.
MESSAGING_ROUTING_KEY - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.HighCardinalityTags
RabbitMQ message routing key.
MESSAGING_SOURCE_NAME - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.HighCardinalityTags
The message destination name.
MESSAGING_SYSTEM - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.LowCardinalityTags
A string identifying the messaging system.
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 class 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
 
MicrometerObservationCollectorBuilder - Class in com.rabbitmq.client.observation.micrometer
Builder to configure and create Micrometer Observation implementation of ObservationCollector.
MicrometerObservationCollectorBuilder() - Constructor for class com.rabbitmq.client.observation.micrometer.MicrometerObservationCollectorBuilder
 
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 Class 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 class 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.
NET_PROTOCOL_NAME - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.LowCardinalityTags
A string identifying the protocol (AMQP).
NET_PROTOCOL_VERSION - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.LowCardinalityTags
A string identifying the protocol version (0.9.1).
NET_SOCK_PEER_ADDR - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.HighCardinalityTags
 
NET_SOCK_PEER_PORT - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation.HighCardinalityTags
 
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.observation.ObservationCollector
 
NO_OP - Static variable in interface com.rabbitmq.client.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
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>, Consumer<HttpURLConnection>) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>, HostnameVerifier, SSLSocketFactory) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, Map<String, String>, HostnameVerifier, SSLSocketFactory, Consumer<HttpURLConnection>) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
OAuth2ClientCredentialsGrantCredentialsProvider(String, String, String, String, HostnameVerifier, SSLSocketFactory) - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider
OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder - Class in com.rabbitmq.client.impl
OAuth2ClientCredentialsGrantCredentialsProvider.TlsConfiguration - Class in com.rabbitmq.client.impl
OAuth2ClientCredentialsGrantCredentialsProvider.Token - Class in com.rabbitmq.client.impl
 
OAuth2ClientCredentialsGrantCredentialsProviderBuilder() - Constructor for class com.rabbitmq.client.impl.OAuth2ClientCredentialsGrantCredentialsProvider.OAuth2ClientCredentialsGrantCredentialsProviderBuilder
 
OAuthTokenManagementException - Exception Class in com.rabbitmq.client.impl
 
OAuthTokenManagementException(String) - Constructor for exception class com.rabbitmq.client.impl.OAuthTokenManagementException
 
OAuthTokenManagementException(String, Throwable) - Constructor for exception class com.rabbitmq.client.impl.OAuthTokenManagementException
 
observationCollector - Variable in class com.rabbitmq.client.impl.AMQConnection
 
observationCollector - Variable in class com.rabbitmq.client.impl.ChannelManager
 
ObservationCollector - Interface in com.rabbitmq.client.observation
API to instrument operations in the AMQP client.
ObservationCollector.BasicGetCall - Interface in com.rabbitmq.client.observation
Underlying basic.get call.
ObservationCollector.ConnectionInfo - Interface in com.rabbitmq.client.observation
Connection information.
ObservationCollector.PublishCall - Interface in com.rabbitmq.client.observation
Underlying publishing call.
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 Class in com.rabbitmq.client
Thrown when the likely cause is an authentication failure.
PossibleAuthenticationFailureException(String) - Constructor for exception class com.rabbitmq.client.PossibleAuthenticationFailureException
 
PossibleAuthenticationFailureException(Throwable) - Constructor for exception class 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
 
PROCESS_OBSERVATION - Enum constant in enum com.rabbitmq.client.observation.micrometer.RabbitMqObservationDocumentation
Observation for processing a message.
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.