A B C D E F G H I J K L M N O P Q R S T U V W _ 

A

abort() - Method in interface com.rabbitmq.client.Channel
Abort this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in interface com.rabbitmq.client.Connection
Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in class com.rabbitmq.client.impl.AMQConnection
Public API - Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Abort this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
abort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
abort(int) - Method in interface com.rabbitmq.client.Connection
Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort(int) - Method in class com.rabbitmq.client.impl.AMQConnection
Public API - Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
abort(int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
abort(int, String) - Method in interface com.rabbitmq.client.Channel
Abort this channel.
abort(int, String) - Method in interface com.rabbitmq.client.Connection
Abort this connection and all its channels.
abort(int, String) - Method in class com.rabbitmq.client.impl.AMQConnection
Public API - Abort this connection and all its channels.
abort(int, String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Abort this channel.
abort(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
abort(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
abort(int, String, int) - Method in interface com.rabbitmq.client.Connection
Abort this connection and all its channels.
abort(int, String, int) - Method in class com.rabbitmq.client.impl.AMQConnection
Public API - Abort this connection and all its channels.
abort(int, String, int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
AbstractFrameHandlerFactory - Class in com.rabbitmq.client.impl
 
AbstractFrameHandlerFactory(int, SocketConfigurator, boolean) - Constructor for class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
 
AbstractMetricsCollector - Class in com.rabbitmq.client.impl
Base class for MetricsCollector.
AbstractMetricsCollector() - Constructor for class com.rabbitmq.client.impl.AbstractMetricsCollector
 
Access() - Constructor for class com.rabbitmq.client.AMQP.Access
 
Access() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Access
 
ACCESS_REFUSED - Static variable in interface com.rabbitmq.client.AMQP
 
Ack(long, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
 
Ack(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
 
ACKNOWLEDGED_MESSAGES - 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
 
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 in com.rabbitmq.client
Thrown when application tries to perform an action on connection/channel which was already closed
AlreadyClosedException(ShutdownSignalException) - Constructor for exception com.rabbitmq.client.AlreadyClosedException
 
AlreadyClosedException(ShutdownSignalException, Throwable) - Constructor for exception com.rabbitmq.client.AlreadyClosedException
 
AMQBasicProperties - Class in com.rabbitmq.client.impl
 
AMQBasicProperties() - Constructor for class com.rabbitmq.client.impl.AMQBasicProperties
 
AMQBasicProperties(DataInputStream) - Constructor for class com.rabbitmq.client.impl.AMQBasicProperties
 
AMQChannel - Class in com.rabbitmq.client.impl
Base class modelling an AMQ channel.
AMQChannel(AMQConnection, int) - Constructor for class com.rabbitmq.client.impl.AMQChannel
Construct a channel on the given connection, with the given channel number.
AMQChannel.BlockingRpcContinuation<T> - Class in com.rabbitmq.client.impl
 
AMQChannel.RpcContinuation - Interface in com.rabbitmq.client.impl
 
AMQChannel.SimpleBlockingRpcContinuation - Class in com.rabbitmq.client.impl
 
AMQCommand - Class in com.rabbitmq.client.impl
AMQP 0-9-1-specific implementation of Command which accumulates method, header and body from a series of frames, unless these are supplied at construction time.
AMQCommand() - Constructor for class com.rabbitmq.client.impl.AMQCommand
Construct a command ready to fill in by reading frames
AMQCommand(Method) - Constructor for class com.rabbitmq.client.impl.AMQCommand
Construct a command with just a method, and without header or body.
AMQCommand(Method, AMQContentHeader, byte[]) - Constructor for class com.rabbitmq.client.impl.AMQCommand
Construct a command with a specified method, header and body.
AMQConnection - Class in com.rabbitmq.client.impl
Concrete class representing and managing an AMQP connection to a broker.
AMQConnection(ConnectionParams, FrameHandler) - Constructor for class com.rabbitmq.client.impl.AMQConnection
 
AMQConnection(ConnectionParams, FrameHandler, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.AMQConnection
Construct a new connection
AMQContentHeader - Class in com.rabbitmq.client.impl
Implementation of ContentHeader - specialized by autogenerated code in AMQP.java.
AMQContentHeader() - Constructor for class com.rabbitmq.client.impl.AMQContentHeader
 
AMQContentHeader(DataInputStream) - Constructor for class com.rabbitmq.client.impl.AMQContentHeader
 
AMQImpl - Class in com.rabbitmq.client.impl
 
AMQImpl() - Constructor for class com.rabbitmq.client.impl.AMQImpl
 
AMQImpl.Access - Class in com.rabbitmq.client.impl
 
AMQImpl.Access.Request - Class in com.rabbitmq.client.impl
 
AMQImpl.Access.RequestOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Ack - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Cancel - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.CancelOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Consume - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.ConsumeOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Deliver - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Get - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.GetEmpty - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.GetOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Nack - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Publish - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Qos - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.QosOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Recover - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.RecoverAsync - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.RecoverOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Reject - Class in com.rabbitmq.client.impl
 
AMQImpl.Basic.Return - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel.Close - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel.CloseOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel.Flow - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel.FlowOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel.Open - Class in com.rabbitmq.client.impl
 
AMQImpl.Channel.OpenOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Confirm - Class in com.rabbitmq.client.impl
 
AMQImpl.Confirm.Select - Class in com.rabbitmq.client.impl
 
AMQImpl.Confirm.SelectOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Blocked - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Close - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.CloseOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Open - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.OpenOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Secure - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.SecureOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Start - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.StartOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Tune - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.TuneOk - Class in com.rabbitmq.client.impl
 
AMQImpl.Connection.Unblocked - Class in com.rabbitmq.client.impl
 
AMQImpl.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.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
 
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.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
 
arguments - Variable in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
 
arguments(Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
 
arity() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
Retrieves the parameter count for this procedure
arraySize(Object[]) - Static method in class com.rabbitmq.client.impl.Frame
Computes the AMQP wire-protocol length of an encoded field-array of type Object[]
arraySize(List<?>) - Static method in class com.rabbitmq.client.impl.Frame
Computes the AMQP 0-9-1 wire-protocol length of an encoded field-array of type List
asLongString(byte[]) - Static method in class com.rabbitmq.client.impl.LongStringHelper
Converts a binary block to a LongString.
asLongString(String) - Static method in class com.rabbitmq.client.impl.LongStringHelper
Converts a String to a LongString using UTF-8 encoding.
asyncCompletableRpc(Method) - Method in interface com.rabbitmq.client.Channel
Asynchronously send a method over this channel.
asyncCompletableRpc(Method) - Method in class com.rabbitmq.client.impl.ChannelN
 
asyncCompletableRpc(Method) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
asyncRpc(Method) - Method in interface com.rabbitmq.client.Channel
Asynchronously send a method over this channel.
asyncRpc(Method) - Method in class com.rabbitmq.client.impl.ChannelN
 
asyncRpc(Method) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
asyncRpc(Method, CompletableFuture<Command>) - Method in class com.rabbitmq.client.impl.AMQChannel
 
AuthenticationFailureException - Exception in com.rabbitmq.client
Thrown when the broker refuses access due to an authentication failure.
AuthenticationFailureException(String) - Constructor for exception com.rabbitmq.client.AuthenticationFailureException
 
autoAck(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
autoDelete() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
 
autoDelete() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
 
autoDelete(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
 
autoDelete(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
 
autoDelete(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
 
autoDelete(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
 
automaticallyRecover(AutorecoveringConnection, Connection) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
AutorecoveringChannel - Class in com.rabbitmq.client.impl.recovery
Channel implementation that is automatically recovered during connection recovery.
AutorecoveringChannel(AutorecoveringConnection, RecoveryAwareChannelN) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
AutorecoveringConnection - Class in com.rabbitmq.client.impl.recovery
Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.
AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, AddressResolver) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, AddressResolver, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, List<Address>) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
available() - Method in class com.rabbitmq.client.impl.TruncatedInputStream
 

B

Basic() - Constructor for class com.rabbitmq.client.AMQP.Basic
 
Basic() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic
 
BASIC - Static variable in class com.rabbitmq.client.MessageProperties
Content-type "application/octet-stream", deliveryMode 1 (nonpersistent), priority zero
basicAck(long, boolean) - Method in interface com.rabbitmq.client.Channel
Acknowledge one or several received messages.
basicAck(long, boolean) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Acknowledge one or several received messages.
basicAck(long, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicAck(long, boolean) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
 
basicAck(Channel, long, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
basicAck(Channel, long, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
 
basicAck(Channel, long, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
basicCancel(Channel, String) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
basicCancel(Channel, String) - Method in interface com.rabbitmq.client.MetricsCollector
 
basicCancel(Channel, String) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
basicCancel(String) - Method in interface com.rabbitmq.client.Channel
Cancel a consumer.
basicCancel(String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Cancel a consumer.
basicCancel(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(Channel, String, boolean) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
basicConsume(Channel, String, boolean) - Method in interface com.rabbitmq.client.MetricsCollector
 
basicConsume(Channel, String, boolean) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
basicConsume(String, boolean, Consumer) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
 
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in interface com.rabbitmq.client.Channel
Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel
Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
 
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a consumer.
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, Consumer) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer.
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and specified arguments.
basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, Consumer) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, Consumer) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, DeliverCallback, CancelCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in interface com.rabbitmq.client.Channel
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag.
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicGet(String, boolean) - Method in interface com.rabbitmq.client.Channel
Retrieve a message from a queue using AMQP.Basic.Get
basicGet(String, boolean) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Retrieve a message from a queue using AMQP.Basic.Get
basicGet(String, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicNack(long, boolean, boolean) - Method in interface com.rabbitmq.client.Channel
Reject one or several received messages.
basicNack(long, boolean, boolean) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Reject one or several received messages.
basicNack(long, boolean, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicNack(long, boolean, boolean) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
 
basicNack(Channel, long) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
basicNack(Channel, long) - Method in interface com.rabbitmq.client.MetricsCollector
 
basicNack(Channel, long) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
BasicProperties - Interface in com.rabbitmq.client
 
BasicProperties() - Constructor for class com.rabbitmq.client.AMQP.BasicProperties
 
BasicProperties(DataInputStream) - Constructor for class com.rabbitmq.client.AMQP.BasicProperties
 
BasicProperties(String, String, Map<String, Object>, Integer, Integer, String, String, String, String, Date, String, String, String, String) - Constructor for class com.rabbitmq.client.AMQP.BasicProperties
 
basicPublish(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
basicPublish(Channel) - Method in interface com.rabbitmq.client.MetricsCollector
 
basicPublish(Channel) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Channel
Publish a message.
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Publish a message.
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Channel
Publish a message.
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Publish a message.
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in interface com.rabbitmq.client.Channel
Publish a message.
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Publish a message.
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
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
 
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
 
bitCount - Variable in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Current flag position counter
bitCount - Variable in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
Position within current flags word
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.
BlockingRpcContinuation() - Constructor for class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
 
BlockingRpcContinuation(Method) - Constructor for class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
 
BlockingValueOrException<V,E extends Throwable & SensibleClone<E>> - Class in com.rabbitmq.utility
 
BlockingValueOrException() - Constructor for class com.rabbitmq.utility.BlockingValueOrException
 
body - Variable in class com.rabbitmq.client.RpcClient.Response
 
build() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Access.RequestOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Cancel.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.CancelOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.ConsumeOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Get.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.GetEmpty.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.QosOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Recover.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.RecoverAsync.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.RecoverOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Reject.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Basic.Return.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Channel.CloseOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Channel.Flow.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Channel.FlowOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Channel.Open.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Confirm.Select.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Confirm.SelectOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Blocked.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.CloseOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Open.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.OpenOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Secure.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.SecureOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.Connection.Unblocked.Builder
 
build() - Method in class com.rabbitmq.client.AMQP.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
 
builder() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
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.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
 
BuiltinExchangeType - Enum in com.rabbitmq.client
Enum for built-in exchange types.
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(String[]) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient
Public API - as JsonRpcClient.call(String,Object[]), but takes the method name from the first entry in args, and the parameters from subsequent entries.
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 - 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_ERROR - Static variable in interface com.rabbitmq.client.AMQP
 
CHANNEL_RPC_TIMEOUT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
CHANNEL_SHOULD_CHECK_RPC_RESPONSE_TYPE - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
CHANNEL_SHUTDOWN_TIMEOUT_MULTIPLIER - Static variable in class com.rabbitmq.client.impl.AMQConnection
 
ChannelContinuationTimeoutException - Exception in com.rabbitmq.client
Exception thrown when a channel times out on a continuation during a RPC call.
ChannelContinuationTimeoutException(TimeoutException, Object, int, Method) - Constructor for exception com.rabbitmq.client.ChannelContinuationTimeoutException
 
channelId(LongString) - Method in class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
 
channelId(String) - Method in class com.rabbitmq.client.AMQP.Channel.OpenOk.Builder
 
ChannelManager - Class in com.rabbitmq.client.impl
Manages a set of channels, indexed by channel number (1.._channelMax).
ChannelManager(ConsumerWorkService, int) - Constructor for class com.rabbitmq.client.impl.ChannelManager
 
ChannelManager(ConsumerWorkService, int, ThreadFactory) - Constructor for class com.rabbitmq.client.impl.ChannelManager
 
ChannelManager(ConsumerWorkService, int, ThreadFactory, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.ChannelManager
 
channelMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
 
channelMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
 
ChannelN - Class in com.rabbitmq.client.impl
Main interface to AMQP protocol functionality.
ChannelN(AMQConnection, int, ConsumerWorkService) - Constructor for class com.rabbitmq.client.impl.ChannelN
Construct a new channel on the given connection with the given channel number.
ChannelN(AMQConnection, int, ConsumerWorkService, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.ChannelN
Construct a new channel on the given connection with the given channel number.
CHANNELS - com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
 
channelShouldCheckRpcResponseType() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
checkClientTrusted(X509Certificate[], String) - Method in class com.rabbitmq.client.TrustEverythingTrustManager
Doesn't even bother looking at its arguments, simply returns, which makes the check succeed.
checkConsumer() - Method in class com.rabbitmq.client.RpcClient
Private API - ensures the RpcClient is correctly open.
checkPreconditions() - Static method in class com.rabbitmq.client.impl.AMQCommand
Called to check internal code assumptions.
checkReply(Map<String, Object>) - Static method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient
Private API - parses a JSON-RPC reply object, checking it for exceptions.
checkServerTrusted(X509Certificate[], String) - Method in class com.rabbitmq.client.TrustEverythingTrustManager
Doesn't even bother looking at its arguments, simply returns, which makes the check succeed.
checkVersion(Version, Version) - Static method in class com.rabbitmq.client.impl.Version
Check compatibility of a client and server version, from the client's perspective.
classId - Variable in exception com.rabbitmq.client.UnknownClassOrMethodId
 
classId(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
 
classId(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
 
cleanStaleState() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
Clean inner state for close connections and channels.
cleanUp() - Method in class com.rabbitmq.client.impl.nio.NioLoopContext
 
clear() - Method in class com.rabbitmq.client.impl.SetQueue
Remove all items from the queue.
clear() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
 
clearBlockedListeners() - Method in interface com.rabbitmq.client.Connection
Remove all BlockedListeners.
clearBlockedListeners() - Method in class com.rabbitmq.client.impl.AMQConnection
 
clearBlockedListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
clearConfirmListeners() - Method in interface com.rabbitmq.client.Channel
Remove all ConfirmListeners.
clearConfirmListeners() - Method in class com.rabbitmq.client.impl.ChannelN
 
clearConfirmListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
clearReturnListeners() - Method in interface com.rabbitmq.client.Channel
Remove all ReturnListeners.
clearReturnListeners() - Method in class com.rabbitmq.client.impl.ChannelN
 
clearReturnListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
CLIENT_PROPERTIES_PREFIX - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
clientProperties(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
 
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 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
 
code - Variable in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
Error code
coerce(String, String) - Static method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient
Private API - used by JsonRpcClient.call(String[]) to ad-hoc convert strings into the required data types for a call.
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
 
com.rabbitmq.client.impl.recovery - package com.rabbitmq.client.impl.recovery
 
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
 
computeDefaultTlsProcotol(String[]) - Static method in class com.rabbitmq.client.ConnectionFactory
 
configurator - Variable in class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
 
configure(Socket) - Method in class com.rabbitmq.client.DefaultSocketConfigurator
Provides a hook to insert custom configuration of the sockets used to connect to an AMQP server before they connect.
configure(Socket) - Method in interface com.rabbitmq.client.SocketConfigurator
Provides a hook to insert custom configuration of the sockets used to connect to an AMQP server before they connect.
configure(SocketChannel) - Method in class com.rabbitmq.client.DefaultSocketChannelConfigurator
Provides a hook to insert custom configuration of the SocketChannels used to connect to an AMQP server before they connect.
configure(SocketChannel) - Method in interface com.rabbitmq.client.SocketChannelConfigurator
Provides a hook to insert custom configuration of the SocketChannels used to connect to an AMQP server before they connect.
configure(SSLEngine) - Method in interface com.rabbitmq.client.SslEngineConfigurator
Provides a hook to insert custom configuration of the SSLEngines used to connect to an AMQP server before they connect.
configureChannelManager(ChannelManager) - Method in class com.rabbitmq.client.impl.AMQConnection
 
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 - 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
 
ConnectionFactory - Class in com.rabbitmq.client
Convenience factory class to facilitate opening a Connection to a RabbitMQ node.
ConnectionFactory() - Constructor for class com.rabbitmq.client.ConnectionFactory
 
ConnectionFactoryConfigurator - Class in com.rabbitmq.client
Helper class to load ConnectionFactory settings from a property file.
ConnectionFactoryConfigurator() - Constructor for class com.rabbitmq.client.ConnectionFactoryConfigurator
 
ConnectionParams - Class in com.rabbitmq.client.impl
 
ConnectionParams() - Constructor for class com.rabbitmq.client.impl.ConnectionParams
 
CONNECTIONS - 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 - 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(Consumer) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
Consumer - Interface in com.rabbitmq.client
Interface for application callback objects to receive notifications and messages from a queue by subscription.
ConsumerCancelledException - Exception in com.rabbitmq.client
 
ConsumerCancelledException() - Constructor for exception com.rabbitmq.client.ConsumerCancelledException
 
consumerCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
 
consumerCount(String) - Method in interface com.rabbitmq.client.Channel
Returns the number of consumers on a queue.
consumerCount(String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Returns the number of consumers on a queue.
consumerCount(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
consumerRecovered(String, String) - Method in interface com.rabbitmq.client.impl.recovery.ConsumerRecoveryListener
 
ConsumerRecoveryListener - Interface in com.rabbitmq.client.impl.recovery
Not part of the public API.
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
 
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
 
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.
correlationId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
 
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
 
createFrameHandlerFactory() - Method in class com.rabbitmq.client.ConnectionFactory
 
createProxy(Class<?>) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient
Public API - gets a dynamic proxy for a particular interface class.
createSocket(String) - Method in class com.rabbitmq.client.impl.SocketFrameHandlerFactory
 

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.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.StandardMetricsCollector
 
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; zero for unlimited
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_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_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
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.
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.
DefaultExceptionHandler - Class in com.rabbitmq.client.impl
Default implementation of ExceptionHandler used by AMQConnection.
DefaultExceptionHandler() - Constructor for class com.rabbitmq.client.impl.DefaultExceptionHandler
 
DefaultMethodVisitor() - Constructor for class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
 
DefaultRecoveryDelayHandler(long) - Constructor for class com.rabbitmq.client.RecoveryDelayHandler.DefaultRecoveryDelayHandler
Default Constructor
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
 
Deliver(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
Deliver(String, long, boolean, String, String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
DeliverCallback - Interface in com.rabbitmq.client
Callback interface to be notified when a message is delivered.
Delivery - Class in com.rabbitmq.client
Encapsulates an arbitrary message - simple "bean" holder structure.
Delivery(Envelope, AMQP.BasicProperties, byte[]) - Constructor for class com.rabbitmq.client.Delivery
 
deliveryMode(Integer) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
 
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
 
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
 
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
 
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
 
deliveryTag(long) - Method in class com.rabbitmq.client.AMQP.Basic.Reject.Builder
 
destination - Variable in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
destination(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
 
destination(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
 
destination(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
DIRECT - com.rabbitmq.client.BuiltinExchangeType
 
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
 
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(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(SocketChannel, SSLEngine) - Static method in class com.rabbitmq.client.impl.nio.SslEngineHelper
 
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
 
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
 
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.impl.nio.SocketChannelRegistration
 
equals(Object) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
equals(Object) - Method in class com.rabbitmq.client.impl.Version
 
error - Variable in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
Error detail object - may not always be present or meaningful
errorResponse(Object, int, String, Object) - Static method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
Construct and encode a JSON-RPC error response for the request ID given, using the code, message, and possible (JSON-encodable) argument passed in.
ExceptionHandler - Interface in com.rabbitmq.client
Interface to an exception-handling object.
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() - 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
 
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
 
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
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
 

F

FANOUT - 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.
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.
fixStackTrace(T) - Static method in class com.rabbitmq.utility.Utility
 
flagWord - Variable in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Current field flag word
flagWord - Variable in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
Current flags word being accumulated
Flow(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
 
Flow(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
 
FlowOk(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
 
FlowOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
 
flush() - Method in class com.rabbitmq.client.impl.AMQConnection
Public API - flush the output buffers
flush() - Method in interface com.rabbitmq.client.impl.FrameHandler
Flush the underlying data connection.
flush() - Method in class com.rabbitmq.client.impl.MethodArgumentWriter
Public API - call this to ensure all accumulated argument values are correctly written to the output stream.
flush() - Method in class com.rabbitmq.client.impl.nio.ByteBufferOutputStream
 
flush() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
 
flush() - Method in class com.rabbitmq.client.impl.nio.SslEngineByteBufferOutputStream
 
flush() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
 
flush() - Method in class com.rabbitmq.client.impl.ValueWriter
Public API - call this to ensure all accumulated values are correctly written to the output stream.
ForgivingExceptionHandler - Class in com.rabbitmq.client.impl
An implementation of ExceptionHandler that does not close channels on unhandled consumer and listener exception.
ForgivingExceptionHandler() - Constructor for class com.rabbitmq.client.impl.ForgivingExceptionHandler
 
Frame - Class in com.rabbitmq.client.impl
Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.
Frame(int, int) - Constructor for class com.rabbitmq.client.impl.Frame
Constructs a frame for output with a type and a channel number and a fresh accumulator waiting for payload.
Frame(int, int, byte[]) - Constructor for class com.rabbitmq.client.impl.Frame
Constructs a frame for input with a type, a channel number and a payload byte array.
FRAME_BODY - Static variable in interface com.rabbitmq.client.AMQP
 
FRAME_END - Static variable in interface com.rabbitmq.client.AMQP
 
FRAME_ERROR - Static variable in interface com.rabbitmq.client.AMQP
 
FRAME_HEADER - Static variable in interface com.rabbitmq.client.AMQP
 
FRAME_HEARTBEAT - Static variable in interface com.rabbitmq.client.AMQP
 
FRAME_METHOD - Static variable in interface com.rabbitmq.client.AMQP
 
FRAME_MIN_SIZE - Static variable in interface com.rabbitmq.client.AMQP
 
FrameBuilder - Class in com.rabbitmq.client.impl.nio
Class to create AMQP frames from a ReadableByteChannel.
FrameBuilder(ReadableByteChannel, ByteBuffer) - Constructor for class com.rabbitmq.client.impl.nio.FrameBuilder
 
FrameHandler - Interface in com.rabbitmq.client.impl
Interface to a frame handler.
FrameHandlerFactory - Interface in com.rabbitmq.client.impl
 
frameMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
 
frameMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
 
FrameWriteRequest - Class in com.rabbitmq.client.impl.nio
 
FrameWriteRequest(Frame) - Constructor for class com.rabbitmq.client.impl.nio.FrameWriteRequest
 
free(int) - Method in class com.rabbitmq.utility.IntAllocator
Make the provided integer available for allocation again.
fromBodyFragment(int, byte[], int, int) - Static method in class com.rabbitmq.client.impl.Frame
 
fromSrvQueryResult(String) - Static method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
 

G

get() - Method in class com.rabbitmq.utility.BlockingCell
Wait for a value, and when one arrives, return it (without clearing it).
get(long) - Method in class com.rabbitmq.utility.BlockingCell
Wait for a value, and when one arrives, return it (without clearing it).
Get(int, String, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Get
 
Get(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Get
 
getAcceptedIssuers() - Method in class com.rabbitmq.client.TrustEverythingTrustManager
Always returns an empty array of X509Certificates.
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
 
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
 
getBytes() - Method in interface com.rabbitmq.client.LongString
Get the content as a byte array.
getCapabilities() - Method in interface com.rabbitmq.client.AMQP.Connection.Open
 
getCapabilities() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
 
getChallenge() - Method in interface com.rabbitmq.client.AMQP.Connection.Secure
 
getChallenge() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
 
getChannel() - Method in exception com.rabbitmq.client.ChannelContinuationTimeoutException
channel that performed the call
getChannel() - Method in class com.rabbitmq.client.DefaultConsumer
Retrieve the channel.
getChannel() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
 
getChannel() - Method in class com.rabbitmq.client.impl.recovery.RecordedEntity
 
getChannel() - Method in class com.rabbitmq.client.RpcClient
Retrieve the channel.
getChannel() - Method in class com.rabbitmq.client.RpcServer
Retrieve the channel.
getChannel(int) - Method in class com.rabbitmq.client.impl.ChannelManager
Looks up a channel on this connection.
getChannelId() - Method in interface com.rabbitmq.client.AMQP.Channel.OpenOk
 
getChannelId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
 
getChannelMax() - Method in interface com.rabbitmq.client.AMQP.Connection.Tune
 
getChannelMax() - Method in interface com.rabbitmq.client.AMQP.Connection.TuneOk
 
getChannelMax() - Method in interface com.rabbitmq.client.Connection
Get the negotiated maximum channel number.
getChannelMax() - Method in class com.rabbitmq.client.impl.AMQConnection
Get the negotiated maximum channel number.
getChannelMax() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
 
getChannelMax() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
 
getChannelMax() - Method in class com.rabbitmq.client.impl.ChannelManager
 
getChannelMax() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getChannelNumber() - Method in interface com.rabbitmq.client.Channel
Retrieve this channel's channel number.
getChannelNumber() - Method in exception com.rabbitmq.client.ChannelContinuationTimeoutException
 
getChannelNumber() - Method in class com.rabbitmq.client.impl.AMQChannel
Public API - Retrieves this channel's channel number.
getChannelNumber() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
getChannelRpcTimeout() - Method in class com.rabbitmq.client.ConnectionFactory
Get the timeout for RPC calls in channels.
getChannelRpcTimeout() - Method in class com.rabbitmq.client.impl.AMQConnection
 
getChannelRpcTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getChannels() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
getChannels() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
 
getClassId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getClassId() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
 
getClassId() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
 
getClassId() - Method in interface com.rabbitmq.client.ContentHeader
Retrieve the class ID (see the spec for a list of allowable IDs).
getClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
 
getClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
 
getClassName() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getClassName() - Method in interface com.rabbitmq.client.ContentHeader
Retrieve the class name, eg "basic" (see the spec for a list of these).
getClientMajor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException
The client's AMQP specification major version.
getClientMinor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException
The client's AMQP specification minor version.
getClientProperties() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
 
getClientProperties() - Method in interface com.rabbitmq.client.Connection
Get a copy of the map of client properties sent to the server
getClientProperties() - Method in class com.rabbitmq.client.ConnectionFactory
Retrieve the currently-configured table of client properties that will be sent to the server during connection startup.
getClientProperties() - Method in class com.rabbitmq.client.impl.AMQConnection
 
getClientProperties() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
 
getClientProperties() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getClientProperties() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getClientProvidedName() - Method in interface com.rabbitmq.client.Connection
Returns client-provided connection name, if any.
getClientProvidedName() - Method in class com.rabbitmq.client.impl.AMQConnection
 
getClientProvidedName() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getClientVersion() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException
The client's AMQP specification version.
getCloseReason() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
getCloseReason() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getCloseReason() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
 
getCloseReason() - Method in interface com.rabbitmq.client.ShutdownNotifier
Get the shutdown reason object
getClusterId() - Method in interface com.rabbitmq.client.AMQP.Basic.GetEmpty
 
getClusterId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getClusterId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
 
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
 
getConnections() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
getConnections() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
 
getConnectionTimeout() - Method in class com.rabbitmq.client.ConnectionFactory
Retrieve the TCP connection timeout.
getConsumedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
getConsumedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
 
getConsumer() - Method in class com.rabbitmq.client.RpcClient
Retrieve the consumer.
getConsumerCount() - Method in interface com.rabbitmq.client.AMQP.Queue.DeclareOk
 
getConsumerCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
 
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Cancel
 
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.CancelOk
 
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
 
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.ConsumeOk
 
getConsumerTag() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
 
getConsumerTag() - Method in class com.rabbitmq.client.DefaultConsumer
Retrieve the consumer tag.
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
 
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
 
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
 
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
 
getConsumerTag() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
getConsumerTag() - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
getConsumerTag() - Method in class com.rabbitmq.client.RpcClient.Response
 
getConsumerTag() - Method in interface com.rabbitmq.client.RpcServer.RpcConsumer
 
getConsumerWorkServiceExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getContentBody() - Method in interface com.rabbitmq.client.Command
Retrieves the body byte array that travelled as part of this Command, if any.
getContentBody() - Method in class com.rabbitmq.client.impl.AMQCommand
Public API - Retrieves the body byte array that travelled as part of this Command, if any.
getContentEncoding() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getContentEncoding() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the contentEncoding field.
getContentHeader() - Method in interface com.rabbitmq.client.Command
Retrieves the ContentHeader subclass instance held as part of this Command, if any.
getContentHeader() - Method in class com.rabbitmq.client.impl.AMQCommand
Public API - Retrieves the ContentHeader subclass instance held as part of this Command, if any.
getContentType() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getContentType() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the contentType field.
getContinuationMap() - Method in class com.rabbitmq.client.RpcClient
Retrieve the continuation map.
getCorrelationId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getCorrelationId() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the correlationId field.
getCorrelationId() - Method in class com.rabbitmq.client.RpcClient
Retrieve the correlation id.
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
 
getExceptionHandler() - Method in interface com.rabbitmq.client.Connection
Get the exception handler.
getExceptionHandler() - Method in class com.rabbitmq.client.ConnectionFactory
Get the exception handler.
getExceptionHandler() - Method in class com.rabbitmq.client.impl.AMQConnection
Protected API - retrieve the current ExceptionHandler
getExceptionHandler() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getExceptionHandler() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Basic.Return
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Exchange.Declare
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Exchange.Delete
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
 
getExchange() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
 
getExchange() - Method in class com.rabbitmq.client.Envelope
Get the name of the exchange included in this parameter envelope
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
 
getExchange() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
 
getExchange() - Method in class com.rabbitmq.client.Return
 
getExchange() - Method in class com.rabbitmq.client.RpcClient
Retrieve the exchange.
getExclusive() - Method in interface com.rabbitmq.client.AMQP.Access.Request
 
getExclusive() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
 
getExclusive() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
 
getExclusive() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
getExclusive() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
 
getExclusive() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
 
getExpectedFrameType() - Method in exception com.rabbitmq.client.UnexpectedFrameError
 
getExpiration() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getExpiration() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the expiration field.
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
 
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.
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
 
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
 
getKnownHosts() - Method in interface com.rabbitmq.client.AMQP.Connection.OpenOk
 
getKnownHosts() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
 
getLastActivity() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
 
getLocalAddress() - Method in class com.rabbitmq.client.impl.AMQConnection
 
getLocalAddress() - Method in interface com.rabbitmq.client.impl.NetworkConnection
Retrieve the local host.
getLocalAddress() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
 
getLocalAddress() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getLocalAddress() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
 
getLocale() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
 
getLocale() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
 
getLocales() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
 
getLocales() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
 
getLocalPort() - Method in class com.rabbitmq.client.impl.AMQConnection
 
getLocalPort() - Method in interface com.rabbitmq.client.impl.NetworkConnection
Retrieve the local port number.
getLocalPort() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
 
getLocalPort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getLocalPort() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
 
getMajor() - Method in class com.rabbitmq.client.impl.Version
Retrieve the major version number.
getMandatory() - Method in interface com.rabbitmq.client.AMQP.Basic.Publish
 
getMandatory() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
getMaxSeenDeliveryTag() - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
 
getMechanism() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
 
getMechanism() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
 
getMechanisms() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
 
getMechanisms() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
 
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
 
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Queue.DeclareOk
 
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Queue.DeleteOk
 
getMessageCount() - Method in interface com.rabbitmq.client.AMQP.Queue.PurgeOk
 
getMessageCount() - Method in class com.rabbitmq.client.GetResponse
Get the server's most recent estimate of the number of messages remaining on the queue.
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
 
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
 
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
 
getMessageCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
 
getMessageId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getMessageId() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the messageId field.
getMethod() - Method in exception com.rabbitmq.client.ChannelContinuationTimeoutException
 
getMethod() - Method in interface com.rabbitmq.client.Command
Retrieves the Method held within this Command.
getMethod() - Method in class com.rabbitmq.client.impl.AMQCommand
Public API - Retrieves the Method held within this Command.
getMethod() - Method in exception com.rabbitmq.client.UnexpectedMethodError
Return the wrapped method.
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
 
getName() - Method in class com.rabbitmq.client.impl.CRDemoMechanism
 
getName() - Method in class com.rabbitmq.client.impl.ExternalMechanism
 
getName() - Method in class com.rabbitmq.client.impl.PlainMechanism
 
getName() - Method in class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
 
getName() - Method in interface com.rabbitmq.client.SaslMechanism
The name of this mechanism (e.g.
getNameToUseForRecovery() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
 
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
 
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.
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
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 class com.rabbitmq.client.impl.ConnectionParams
 
getPayload() - Method in class com.rabbitmq.client.impl.Frame
Public API - retrieves the frame payload
getPort() - Method in class com.rabbitmq.client.Address
Get the port number
getPort() - Method in interface com.rabbitmq.client.Connection
Retrieve the port number.
getPort() - Method in class com.rabbitmq.client.ConnectionFactory
 
getPort() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
 
getPort() - Method in class com.rabbitmq.client.impl.AMQConnection
Retrieve the port number.
getPort() - Method in interface com.rabbitmq.client.impl.NetworkConnection
Retrieve port number of peer.
getPort() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
 
getPort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getPort() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
 
getPrefetchCount() - Method in interface com.rabbitmq.client.AMQP.Basic.Qos
 
getPrefetchCount() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
getPrefetchSize() - Method in interface com.rabbitmq.client.AMQP.Basic.Qos
 
getPrefetchSize() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
getPriority() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getPriority() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the priority field.
getPriority() - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver.SrvRecord
 
getProcedure(String, int) - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
Looks up a single ProcedureDescription by name and arity.
getProcs() - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription
Gets a collection of all ProcedureDescription for this service
getProperties() - Method in class com.rabbitmq.client.Delivery
Retrieve the message properties.
getProperties() - Method in class com.rabbitmq.client.Return
 
getProperties() - Method in class com.rabbitmq.client.RpcClient.Response
 
getProps() - Method in class com.rabbitmq.client.GetResponse
Get the AMQP.BasicProperties included in this response
getPublishedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
getPublishedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Basic.Consume
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Basic.Get
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Bind
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Declare
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.DeclareOk
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Delete
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Purge
 
getQueue() - Method in interface com.rabbitmq.client.AMQP.Queue.Unbind
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
 
getQueue() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
 
getQueue() - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
getQueueName() - Method in class com.rabbitmq.client.RpcServer
Retrieve the queue name.
getRead() - Method in interface com.rabbitmq.client.AMQP.Access.Request
 
getRead() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
getReadByteBufferSize() - Method in class com.rabbitmq.client.impl.nio.NioParams
 
getRealm() - Method in interface com.rabbitmq.client.AMQP.Access.Request
 
getRealm() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
getReason() - Method in interface com.rabbitmq.client.AMQP.Connection.Blocked
 
getReason() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
 
getReason() - Method in exception com.rabbitmq.client.ShutdownSignalException
 
getReceivedFrame() - Method in exception com.rabbitmq.client.UnexpectedFrameError
 
getRecordedExchanges() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getRecordedQueues() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getRecoveryDelayHandler() - Method in class com.rabbitmq.client.ConnectionFactory
Returns automatic connection recovery delay handler.
getRecoveryDelayHandler() - Method in class com.rabbitmq.client.impl.ConnectionParams
Get the recovery delay handler.
getRedelivered() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
 
getRedelivered() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
 
getRedelivered() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
getRedelivered() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
 
getReference() - Method in exception com.rabbitmq.client.ShutdownSignalException
 
getRejectedMessages() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
getRejectedMessages() - Method in class com.rabbitmq.client.impl.StandardMetricsCollector
 
getReply() - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
 
getReply(int) - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
 
getReplyCode() - Method in interface com.rabbitmq.client.AMQP.Basic.Return
 
getReplyCode() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
 
getReplyCode() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
 
getReplyCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
getReplyCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
 
getReplyCode() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
 
getReplyCode() - Method in class com.rabbitmq.client.Return
 
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.
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
getReturn() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
Getter for return type
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.Return
 
getRoutingKey() - Method in class com.rabbitmq.client.RpcClient
Retrieve the routing key.
getSaslConfig() - Method in class com.rabbitmq.client.ConnectionFactory
Gets the sasl config to use when authenticating
getSaslConfig() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getSaslMechanism(String[]) - Method in class com.rabbitmq.client.DefaultSaslConfig
 
getSaslMechanism(String[]) - Method in class com.rabbitmq.client.impl.CRDemoMechanism.CRDemoSaslConfig
 
getSaslMechanism(String[]) - Method in class com.rabbitmq.client.JDKSaslConfig
 
getSaslMechanism(String[]) - Method in interface com.rabbitmq.client.SaslConfig
 
getSerialVersionUID() - Static method in exception com.rabbitmq.client.UnexpectedFrameError
 
getServerMajor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException
The server's AMQP specification major version.
getServerMinor() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException
The server's AMQP specification minor version.
getServerProperties() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
 
getServerProperties() - Method in interface com.rabbitmq.client.Connection
Retrieve the server properties.
getServerProperties() - Method in class com.rabbitmq.client.impl.AMQConnection
Retrieve the server properties.
getServerProperties() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
 
getServerProperties() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
getServerVersion() - Method in exception com.rabbitmq.client.ProtocolVersionMismatchException
The server's AMQP specification version.
getServiceDescription() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient
Public API - gets the service description record that this service loaded from the server itself at construction time.
getServiceDescription() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
Public API - gets the service description record that this service built from interfaceClass at construction time.
getShutdownExecutor() - Method in class com.rabbitmq.client.impl.ChannelManager
 
getShutdownExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getShutdownTimeout() - Method in class com.rabbitmq.client.ConnectionFactory
Retrieve the shutdown timeout.
getShutdownTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
 
getShutdownTimeout() - Method in class com.rabbitmq.client.impl.ConsumerWorkService
 
getSocketChannelConfigurator() - Method in class com.rabbitmq.client.impl.nio.NioParams
 
getSocketConfigurator() - Method in class com.rabbitmq.client.ConnectionFactory
Get the socket configurator.
getSocketFactory() - Method in class com.rabbitmq.client.ConnectionFactory
Retrieve the socket factory used to make connections with.
getSource() - Method in interface com.rabbitmq.client.AMQP.Exchange.Bind
 
getSource() - Method in interface com.rabbitmq.client.AMQP.Exchange.Unbind
 
getSource() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
 
getSource() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
 
getSource() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
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.
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
 
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
 
getTimestamp() - Method in class com.rabbitmq.client.AMQP.BasicProperties
 
getTimestamp() - Method in interface com.rabbitmq.client.BasicProperties
Retrieve the value in the timestamp field.
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
 
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 class com.rabbitmq.client.impl.ConnectionParams
 
getValue() - Method in class com.rabbitmq.utility.ValueOrException
Retrieve value or throw exception
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
 
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
 
global() - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
 
global(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
 

H

handle() - Method in interface com.rabbitmq.client.UnblockedCallback
 
handle(long, boolean) - Method in interface com.rabbitmq.client.ConfirmCallback
 
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
 
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
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
 
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.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.impl.nio.SocketChannelRegistration
 
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 - 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
 
help - Variable in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
Human-readable instructions for how to get information on the procedure's operation
help - Variable in class com.rabbitmq.tools.jsonrpc.ServiceDescription
Human-readable instructions for how to get information on the service's operation
HOST - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
 

I

id - Variable in class com.rabbitmq.tools.jsonrpc.ServiceDescription
ID for the service
idempotent - Variable in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
True if this procedure is idempotent, that is, can be accessed via HTTP GET
ifEmpty() - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
 
ifEmpty(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
 
ifUnused() - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
 
ifUnused() - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
 
ifUnused(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
 
ifUnused(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
 
immediate() - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
 
immediate(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
 
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
Increments channel count.
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
incrementChannelCount(Channel) - Method in class com.rabbitmq.client.impl.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.StandardMetricsCollector
 
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.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].
interfaceClass - Variable in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
The interface this server implements.
interfaceInstance - Variable in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
The instance backing this server.
internal() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
 
internal(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
 
INTERNAL_ERROR - Static variable in interface com.rabbitmq.client.AMQP
 
internal_getMethod() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
Private API - used to get the reflected method object, for servers
internal_getParams() - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
Gets an array of parameter descriptions for all this procedure's parameters
INVALID_PATH - Static variable in interface com.rabbitmq.client.AMQP
 
invoke(Object, Method, Object[]) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient
Public API - implements InvocationHandler.invoke.
isAllowedToModifyThreads() - Static method in class com.rabbitmq.client.impl.Environment
 
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
 
isEmpty() - Method in class com.rabbitmq.client.impl.SetQueue
 
isHardError() - Method in exception com.rabbitmq.client.ShutdownSignalException
 
isInitiatedByApplication() - Method in exception com.rabbitmq.client.ShutdownSignalException
 
isOpen() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
isOpen() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
isOpen() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
 
isOpen() - Method in interface com.rabbitmq.client.ShutdownNotifier
Determine whether the component is currently open.
isOutstandingRpc() - Method in class com.rabbitmq.client.impl.AMQChannel
 
isRedeliver() - Method in class com.rabbitmq.client.Envelope
Get the redelivery flag included in this parameter envelope.
isResponseCompatibleWithRequest(Method, Method) - Static method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
 
isRunning() - Method in class com.rabbitmq.client.impl.AMQConnection
 
isServerNamed() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
 
isSSL() - Method in class com.rabbitmq.client.ConnectionFactory
 
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
 
iterator() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
Returns an iterator over the elements in this queue in proper sequence.

J

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
 
JSONReader() - Constructor for class com.rabbitmq.tools.json.JSONReader
 
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.
JsonRpcException - Exception in com.rabbitmq.tools.jsonrpc
Thrown when a JSON-RPC service indicates an error occurred during a call.
JsonRpcException() - Constructor for exception com.rabbitmq.tools.jsonrpc.JsonRpcException
 
JsonRpcException(Map<String, Object>) - Constructor for exception com.rabbitmq.tools.jsonrpc.JsonRpcException
 
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, 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.
JSONSerializable - Interface in com.rabbitmq.tools.json
Interface for classes that wish to control their own serialization.
jsonSerialize(JSONWriter) - Method in interface com.rabbitmq.tools.json.JSONSerializable
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
 
JSONWriter() - Constructor for class com.rabbitmq.tools.json.JSONWriter
 
JSONWriter(boolean) - Constructor for class com.rabbitmq.tools.json.JSONWriter
 

K

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

L

length() - Method in interface com.rabbitmq.client.LongString
 
limit(K) - Method in class com.rabbitmq.client.impl.WorkPool
 
ListAddressResolver - Class in com.rabbitmq.client
Simple implementation of AddressResolver that returns a fixed list.
ListAddressResolver(List<Address>) - Constructor for class com.rabbitmq.client.ListAddressResolver
 
load(ConnectionFactory, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
load(ConnectionFactory, String, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
load(ConnectionFactory, Map<String, String>) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
load(ConnectionFactory, Map<String, String>, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
load(ConnectionFactory, Properties) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
load(ConnectionFactory, Properties, String) - Static method in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
load(String) - Method in class com.rabbitmq.client.ConnectionFactory
Load settings from a property file.
load(String, String) - Method in class com.rabbitmq.client.ConnectionFactory
Load settings from a property file.
load(Map<String, String>) - Method in class com.rabbitmq.client.ConnectionFactory
Load settings from a Map instance.
load(Map<String, String>, String) - Method in class com.rabbitmq.client.ConnectionFactory
Load settings from a Map instance.
load(Properties) - Method in class com.rabbitmq.client.ConnectionFactory
Load settings from a Properties instance.
load(Properties, String) - Method in class com.rabbitmq.client.ConnectionFactory
Load settings from a Properties instance.
locale(String) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
 
locales(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
 
locales(String) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
 
log(String, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
 
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
 
lookupSrvRecords(String, String) - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver
 

M

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

There are some restrictions on the values appearing in the table:
they must be of type String, LongString, Integer, BigDecimal, Date, or (recursively) a Map of the enclosing type.
MapRpcServer - Class in com.rabbitmq.client
Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies.
MapRpcServer(Channel) - Constructor for class com.rabbitmq.client.MapRpcServer
 
MapRpcServer(Channel, String) - Constructor for class com.rabbitmq.client.MapRpcServer
 
mapSrvRecord(String) - Method in class com.rabbitmq.client.DnsSrvRecordAddressResolver
 
mark(int) - Method in class com.rabbitmq.client.impl.TruncatedInputStream
 
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
Marks the event of an acknowledged message.
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
markAcknowledgedMessage() - Method in class com.rabbitmq.client.impl.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.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.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.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
 
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
 
message - Variable in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
Error message
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
 
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
 
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeleteOk.Builder
 
messageCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.PurgeOk.Builder
 
messageCount(String) - Method in interface com.rabbitmq.client.Channel
Returns the number of messages in a queue ready to be delivered to consumers.
messageCount(String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Returns the number of messages in a queue ready to be delivered to consumers.
messageCount(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
messageId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
 
MessageProperties - Class in com.rabbitmq.client
Constant holder class with useful static instances of AMQContentHeader.
MessageProperties() - Constructor for class com.rabbitmq.client.MessageProperties
 
Method - Class in com.rabbitmq.client.impl
Base class for AMQP method objects, specialized by autogenerated code in AMQP.java.
Method - Interface in com.rabbitmq.client
Public interface to objects representing an AMQP 0-9-1 method
Method() - Constructor for class com.rabbitmq.client.impl.Method
 
MethodArgumentReader - Class in com.rabbitmq.client.impl
Parses AMQP wire-protocol Method arguments from a DataInputStream.
MethodArgumentReader(ValueReader) - Constructor for class com.rabbitmq.client.impl.MethodArgumentReader
Construct a MethodArgumentReader from the given ValueReader.
MethodArgumentWriter - Class in com.rabbitmq.client.impl
Generates AMQP wire-protocol encoded arguments.
MethodArgumentWriter(ValueWriter) - Constructor for class com.rabbitmq.client.impl.MethodArgumentWriter
Constructs a MethodArgumentWriter targetting the given DataOutputStream.
methodId - Variable in exception com.rabbitmq.client.UnknownClassOrMethodId
 
methodId(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
 
methodId(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
 
metricsCollector - Variable in class com.rabbitmq.client.impl.AMQConnection
 
metricsCollector - Variable in class com.rabbitmq.client.impl.ChannelManager
 
MetricsCollector - 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(Function<MicrometerMetricsCollector.Metrics, Object>) - Constructor for class com.rabbitmq.client.impl.MicrometerMetricsCollector
 
MicrometerMetricsCollector.Metrics - Enum in com.rabbitmq.client.impl
 
MINIMAL_BASIC - Static variable in class com.rabbitmq.client.MessageProperties
Empty basic properties, with no fields set
MINIMAL_PERSISTENT_BASIC - Static variable in class com.rabbitmq.client.MessageProperties
Empty basic properties, with only deliveryMode set to 2 (persistent)
MINOR - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
 
MissedHeartbeatException - Exception in com.rabbitmq.client
Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down.
MissedHeartbeatException(String) - Constructor for exception com.rabbitmq.client.MissedHeartbeatException
 
multiple() - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
 
multiple() - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
 
multiple(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
 
multiple(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
 

N

Nack(long, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
 
Nack(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
 
name - Variable in class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
 
name - Variable in exception com.rabbitmq.tools.jsonrpc.JsonRpcException
Usually the constant string, "JSONRPCError"
name - Variable in class com.rabbitmq.tools.jsonrpc.ParameterDescription
The parameter name.
name - Variable in class com.rabbitmq.tools.jsonrpc.ProcedureDescription
Procedure name
name - Variable in class com.rabbitmq.tools.jsonrpc.ServiceDescription
The service name
needToDispatchIoError(SocketChannelFrameHandlerState) - Method in class com.rabbitmq.client.impl.nio.NioLoop
 
negotiateChannelMax(int, int) - Method in class com.rabbitmq.client.impl.AMQConnection
Private API, allows for easier simulation of bogus clients.
NetworkConnection - Interface in com.rabbitmq.client.impl
 
newChannel(Channel) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
newChannel(Channel) - Method in interface com.rabbitmq.client.MetricsCollector
 
newChannel(Channel) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
newConnection() - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection.
newConnection() - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
 
newConnection(Address[]) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection, picking the first available address from the list.
newConnection(Address[], String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection with a client-provided name, picking the first available address from the list.
newConnection(AddressResolver) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection, picking the first available address from the list provided by the AddressResolver.
newConnection(Connection) - Method in class com.rabbitmq.client.impl.AbstractMetricsCollector
 
newConnection(Connection) - Method in interface com.rabbitmq.client.MetricsCollector
 
newConnection(Connection) - Method in class com.rabbitmq.client.NoOpMetricsCollector
 
newConnection(String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection.
newConnection(ExecutorService) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection.
newConnection(ExecutorService, Address[]) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection, picking the first available address from the list.
newConnection(ExecutorService, Address[], String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection with a client-provided name, picking the first available address from the list.
newConnection(ExecutorService, AddressResolver) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection, picking the first available address from the list provided by the AddressResolver.
newConnection(ExecutorService, AddressResolver, String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection with a client-provided name, picking the first available address from the list provided by the AddressResolver.
newConnection(ExecutorService, String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection.
newConnection(ExecutorService, List<Address>) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection, picking the first available address from the list.
newConnection(ExecutorService, List<Address>, String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection with a client-provided name, picking the first available address from the list.
newConnection(List<Address>) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection, picking the first available address from the list.
newConnection(List<Address>, String) - Method in class com.rabbitmq.client.ConnectionFactory
Create a new broker connection with a client-provided name, picking the first available address from the list.
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
 
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
 
NO_CONSUMERS - Static variable in interface com.rabbitmq.client.AMQP
 
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

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
 
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
 
outOfBand(String) - Method in class com.rabbitmq.client.AMQP.Channel.Open.Builder
 

P

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
 
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
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
 
peek() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
 
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.SetQueue
Remove the head of the queue and return it.
poll() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
 
poll(long, TimeUnit) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
 
PORT - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
 
PORT - Static variable in class com.rabbitmq.client.ConnectionFactoryConfigurator
 
portOrDefault(int, boolean) - Static method in class com.rabbitmq.client.ConnectionFactory
 
PossibleAuthenticationFailureException - Exception in com.rabbitmq.client
Thrown when the likely cause is an authentication failure.
PossibleAuthenticationFailureException(String) - Constructor for exception com.rabbitmq.client.PossibleAuthenticationFailureException
 
PossibleAuthenticationFailureException(Throwable) - Constructor for exception com.rabbitmq.client.PossibleAuthenticationFailureException
 
postprocessReplyProperties(Delivery, AMQP.BasicProperties.Builder) - Method in class com.rabbitmq.client.RpcServer
Gives a chance to set/modify reply properties after the handling call
PRECONDITION_FAILED - Static variable in interface com.rabbitmq.client.AMQP
 
prefetchCount(int) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
 
prefetchSize(int) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
 
preprocessReplyProperties(Delivery, AMQP.BasicProperties.Builder) - Method in class com.rabbitmq.client.RpcServer
Gives a chance to set/modify reply properties before handling call.
primitiveCall(byte[]) - Method in class com.rabbitmq.client.RpcClient
Perform a simple byte-array-based RPC roundtrip.
primitiveCall(AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.RpcClient
 
priority(Integer) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
 
ProcedureDescription - Class in com.rabbitmq.tools.jsonrpc
Description of a single JSON-RPC procedure.
ProcedureDescription() - Constructor for class com.rabbitmq.tools.jsonrpc.ProcedureDescription
 
ProcedureDescription(Method) - Constructor for class com.rabbitmq.tools.jsonrpc.ProcedureDescription
 
ProcedureDescription(Map<String, Object>) - Constructor for class com.rabbitmq.tools.jsonrpc.ProcedureDescription
 
processAsync(Command) - Method in class com.rabbitmq.client.impl.AMQChannel
Protected API - called by nextCommand to check possibly handle an incoming Command before it is returned to the caller of nextCommand.
processAsync(Command) - Method in class com.rabbitmq.client.impl.ChannelN
Protected API - Filters the inbound command stream, processing Basic.Deliver, Basic.Return and Channel.Close specially.
processControlCommand(Command) - Method in class com.rabbitmq.client.impl.AMQConnection
Handles incoming control commands on channel zero.
processDelivery(Command, AMQImpl.Basic.Deliver) - Method in class com.rabbitmq.client.impl.ChannelN
 
processDelivery(Command, AMQImpl.Basic.Deliver) - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
 
processRequest(Delivery) - Method in class com.rabbitmq.client.RpcServer
Private API - Process a single request.
processShutdownSignal(ShutdownSignalException, boolean, boolean) - Method in class com.rabbitmq.client.impl.AMQChannel
Protected API - respond, in the driver thread, to a ShutdownSignalException.
processShutdownSignal(ShutdownSignalException, boolean, boolean) - Method in class com.rabbitmq.client.impl.ChannelN
Protected API - overridden to quiesce consumer work and broadcast the signal to all consumers after calling the superclass's method.
properties - Variable in class com.rabbitmq.client.RpcClient.Response
 
PROTOCOL() - Constructor for class com.rabbitmq.client.AMQP.PROTOCOL
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
 
protocolClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
 
protocolClassId() - Method in class com.rabbitmq.client.impl.Method
Retrieve the protocol class ID
protocolClassId() - Method in interface com.rabbitmq.client.Method
Retrieve the protocol class ID
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
 
protocolMethodId() - Method in class com.rabbitmq.client.impl.Method
Retrieve the protocol method ID
protocolMethodId() - Method in interface com.rabbitmq.client.Method
Retrieve the protocol method ID
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
 
protocolMethodName() - Method in class com.rabbitmq.client.impl.Method
Retrieve the method name
protocolMethodName() - Method in interface com.rabbitmq.client.Method
Retrieve the method name
protocolVersionMismatch(DataInputStream) - Static method in class com.rabbitmq.client.impl.Frame
Private API - A protocol version mismatch is detected by checking the three next bytes if a frame type of (int)'A' is read from an input stream.
ProtocolVersionMismatchException - Exception in com.rabbitmq.client
Thrown to indicate that the server does not support the wire protocol version we requested immediately after opening the TCP socket.
ProtocolVersionMismatchException(Version, Version) - Constructor for exception com.rabbitmq.client.ProtocolVersionMismatchException
 
publish(AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.RpcClient
 
Publish(int, String, String, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
Publish(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
 
PUBLISHED_MESSAGES - com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
 
Purge(int, String, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
 
Purge(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
 
PurgeOk(int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
 
PurgeOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
 
put(E) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
Adds the specified element to the tail of this queue, waiting if necessary for space to become available.

Q

Qos(int, int, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
Qos(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
 
QosOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
 
QosOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Basic.Get.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Queue.Purge.Builder
 
queue(String) - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
 
Queue() - Constructor for class com.rabbitmq.client.AMQP.Queue
 
Queue() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue
 
queueBind(String, String, String) - Method in interface com.rabbitmq.client.Channel
Bind a queue to an exchange, with no extra arguments.
queueBind(String, String, String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Bind a queue to an exchange, with no extra arguments.
queueBind(String, String, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueBind(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel
Bind a queue to an exchange.
queueBind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Bind a queue to an exchange.
queueBind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueBindNoWait(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel
Same as Channel.queueBind(String, String, String, java.util.Map) but sets nowait parameter to true and returns void (as there will be no response from the server).
queueBindNoWait(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Same as Channel.queueBind(String, String, String, java.util.Map) but sets nowait parameter to true and returns void (as there will be no response from the server).
queueBindNoWait(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDeclare() - Method in interface com.rabbitmq.client.Channel
Actively declare a server-named exclusive, autodelete, non-durable queue.
queueDeclare() - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Actively declare a server-named exclusive, autodelete, non-durable queue.
queueDeclare() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDeclare(String, boolean, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel
Declare a queue
queueDeclare(String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Declare a queue
queueDeclare(String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDeclareNoWait(String, boolean, boolean, boolean, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel
Like Channel.queueDeclare(String, boolean, boolean, boolean, java.util.Map) but sets nowait flag to true and returns no result (as there will be no response from the server).
queueDeclareNoWait(String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Like Channel.queueDeclare(String, boolean, boolean, boolean, java.util.Map) but sets nowait flag to true and returns no result (as there will be no response from the server).
queueDeclareNoWait(String, boolean, boolean, boolean, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDeclarePassive(String) - Method in interface com.rabbitmq.client.Channel
Declare a queue passively; i.e., check if it exists.
queueDeclarePassive(String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Declare a queue passively; i.e., check if it exists.
queueDeclarePassive(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDelete(String) - Method in interface com.rabbitmq.client.Channel
Delete a queue, without regard for whether it is in use or has messages on it
queueDelete(String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Delete a queue, without regard for whether it is in use or has messages on it
queueDelete(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDelete(String, boolean, boolean) - Method in interface com.rabbitmq.client.Channel
Delete a queue
queueDelete(String, boolean, boolean) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Delete a queue
queueDelete(String, boolean, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueDeleteNoWait(String, boolean, boolean) - Method in interface com.rabbitmq.client.Channel
Like Channel.queueDelete(String, boolean, boolean) but sets nowait parameter to true and returns nothing (as there will be no response from the server).
queueDeleteNoWait(String, boolean, boolean) - Method in class com.rabbitmq.client.impl.ChannelN
 
queueDeleteNoWait(String, boolean, boolean) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queuePurge(String) - Method in interface com.rabbitmq.client.Channel
Purges the contents of the given queue.
queuePurge(String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Purges the contents of the given queue.
queuePurge(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueRecovered(String, String) - Method in interface com.rabbitmq.client.impl.recovery.QueueRecoveryListener
 
QueueRecoveryListener - Interface in com.rabbitmq.client.impl.recovery
Not part of the public API.
queueUnbind(String, String, String) - Method in interface com.rabbitmq.client.Channel
Unbinds a queue from an exchange, with no extra arguments.
queueUnbind(String, String, String) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Unbinds a queue from an exchange, with no extra arguments.
queueUnbind(String, String, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
queueUnbind(String, String, String, Map<String, Object>) - Method in interface com.rabbitmq.client.Channel
Unbind a queue from an exchange.
queueUnbind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.ChannelN
Public API - Unbind a queue from an exchange.
queueUnbind(String, String, String, Map<String, Object>) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
quiescingAsyncRpc(Method, CompletableFuture<Command>) - Method in class com.rabbitmq.client.impl.AMQChannel
 
quiescingRpc(Method, AMQChannel.RpcContinuation) - Method in class com.rabbitmq.client.impl.AMQChannel
 
quiescingTransmit(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel
 
quiescingTransmit(Method) - Method in class com.rabbitmq.client.impl.AMQChannel
 

R

read() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
 
read() - Method in class com.rabbitmq.client.impl.TruncatedInputStream
 
read(boolean) - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
 
read(byte[], int, int) - Method in class com.rabbitmq.client.impl.TruncatedInputStream
 
read(String) - Method in class com.rabbitmq.tools.json.JSONReader
 
readBit() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads a bit/boolean argument.
readContentHeaderFrom(DataInputStream) - Static method in class com.rabbitmq.client.impl.AMQImpl
 
readFlagWord() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
 
readFrame() - Method in interface com.rabbitmq.client.impl.FrameHandler
Read a Frame from the underlying data connection.
readFrame() - Method in class com.rabbitmq.client.impl.nio.FrameBuilder
Read a frame from the network.
readFrame() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
 
readFrame() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
 
readFrom(DataInputStream) - Static method in class com.rabbitmq.client.impl.Frame
Protected API - Factory method to instantiate a Frame by reading an AMQP-wire-protocol frame from the given input stream.
readLong() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP integer content header field.
readLong() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads an integer argument.
readLong() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads an integer.
readLonglong() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP long integer content header field.
readLonglong() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads a long integer argument.
readLonglong() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads a long integer.
readLongstr() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP "long string" (binary) content header field.
readLongstr() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads a long string argument.
readLongstr() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads a long string.
readMethodFrom(DataInputStream) - Static method in class com.rabbitmq.client.impl.AMQImpl
 
readOctet() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP octet content header field.
readOctet() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads an octet argument.
readOctet() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads an octet.
readPresence() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
 
readShort() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP short integer content header field.
readShort() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads a short integer argument.
readShort() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads a short integer.
readShortstr() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP short string content header field.
readShortstr() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads a short string argument.
readShortstr() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads a short string.
readTable() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP table content header field.
readTable() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads a table argument.
readTable() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads a table.
readTimestamp() - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyReader
Reads and returns an AMQP timestamp content header field.
readTimestamp() - Method in class com.rabbitmq.client.impl.MethodArgumentReader
Public API - reads an timestamp argument.
readTimestamp() - Method in class com.rabbitmq.client.impl.ValueReader
Public API - reads an timestamp.
realm(String) - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
 
reason(String) - Method in class com.rabbitmq.client.AMQP.Connection.Blocked.Builder
 
RecordedBinding - Class in com.rabbitmq.client.impl.recovery
 
RecordedBinding(AutorecoveringChannel) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedBinding
 
RecordedConsumer - Class in com.rabbitmq.client.impl.recovery
 
RecordedConsumer(AutorecoveringChannel, String) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
RecordedEntity - Class in com.rabbitmq.client.impl.recovery
 
RecordedEntity(AutorecoveringChannel) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedEntity
 
RecordedExchange - Class in com.rabbitmq.client.impl.recovery
 
RecordedExchange(AutorecoveringChannel, String) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedExchange
 
RecordedExchangeBinding - Class in com.rabbitmq.client.impl.recovery
 
RecordedExchangeBinding(AutorecoveringChannel) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedExchangeBinding
 
RecordedNamedEntity - Class in com.rabbitmq.client.impl.recovery
 
RecordedNamedEntity(AutorecoveringChannel, String) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
 
RecordedQueue - Class in com.rabbitmq.client.impl.recovery
 
RecordedQueue(AutorecoveringChannel, String) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedQueue
 
RecordedQueueBinding - Class in com.rabbitmq.client.impl.recovery
 
RecordedQueueBinding(AutorecoveringChannel) - Constructor for class com.rabbitmq.client.impl.recovery.RecordedQueueBinding
 
recover() - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
recover() - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
 
recover() - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange
 
recover() - Method in class com.rabbitmq.client.impl.recovery.RecordedExchangeBinding
 
recover() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
 
recover() - Method in class com.rabbitmq.client.impl.recovery.RecordedQueueBinding
 
Recover(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
 
Recover(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
 
Recoverable - Interface in com.rabbitmq.client
Provides a way to register (network, AMQP 0-9-1) connection recovery callbacks.
RecoverableChannel - Interface in com.rabbitmq.client
Convenient interface when working against auto-recovery channels.
RecoverableConnection - Interface in com.rabbitmq.client
Convenient interface when working against auto-recovery connections.
RecoverAsync(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
 
RecoverAsync(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
 
RecoverOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
 
RecoverOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
 
RecoveryAwareAMQConnection - Class in com.rabbitmq.client.impl.recovery
AMQConnection modification that uses RecoveryAwareChannelN
RecoveryAwareAMQConnection(ConnectionParams, FrameHandler) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnection
 
RecoveryAwareAMQConnection(ConnectionParams, FrameHandler, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnection
 
RecoveryAwareAMQConnectionFactory - Class in com.rabbitmq.client.impl.recovery
 
RecoveryAwareAMQConnectionFactory(ConnectionParams, FrameHandlerFactory, AddressResolver) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
 
RecoveryAwareAMQConnectionFactory(ConnectionParams, FrameHandlerFactory, AddressResolver, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
 
RecoveryAwareAMQConnectionFactory(ConnectionParams, FrameHandlerFactory, List<Address>) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
 
RecoveryAwareChannelManager - Class in com.rabbitmq.client.impl.recovery
 
RecoveryAwareChannelManager(ConsumerWorkService, int) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelManager
 
RecoveryAwareChannelManager(ConsumerWorkService, int, ThreadFactory) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelManager
 
RecoveryAwareChannelManager(ConsumerWorkService, int, ThreadFactory, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelManager
 
RecoveryAwareChannelN - Class in com.rabbitmq.client.impl.recovery
ChannelN modification that keeps track of delivery tags and avoids sending
RecoveryAwareChannelN(AMQConnection, int, ConsumerWorkService) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
Construct a new channel on the given connection with the given channel number.
RecoveryAwareChannelN(AMQConnection, int, ConsumerWorkService, MetricsCollector) - Constructor for class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
Construct a new channel on the given connection with the given channel number.
recoveryCanBegin(ShutdownSignalException) - Method in interface com.rabbitmq.client.impl.recovery.RecoveryCanBeginListener
 
RecoveryCanBeginListener - Interface in com.rabbitmq.client.impl.recovery
Used internally to indicate when connection recovery can begin.
RecoveryDelayHandler - Interface in com.rabbitmq.client
A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.
RecoveryDelayHandler.DefaultRecoveryDelayHandler - Class in com.rabbitmq.client
Basic implementation of RecoveryDelayHandler that returns the network recovery interval each time.
RecoveryDelayHandler.ExponentialBackoffDelayHandler - Class in com.rabbitmq.client
Backoff implementation of RecoveryDelayHandler that uses the Fibonacci sequence (by default) to increase the recovery delay time after each failed attempt.
RecoveryListener - Interface in com.rabbitmq.client
A RecoveryListener receives notifications about completed automatic connection recovery.
redelivered() - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
 
redelivered() - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
 
redelivered(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
 
redelivered(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
 
registerFrameHandlerState(SocketChannelFrameHandlerState, int) - Method in class com.rabbitmq.client.impl.nio.SelectorHolder
 
registerKey(Channel) - Method in class com.rabbitmq.client.impl.ConsumerWorkService
 
registerKey(K) - Method in class com.rabbitmq.client.impl.WorkPool
Add client key to pool of item queues, with an empty queue.
Reject(long, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
 
Reject(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
 
REJECTED_MESSAGES - com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics
 
releaseChannelNumber(ChannelN) - Method in class com.rabbitmq.client.impl.ChannelManager
Remove the channel from the channel map and free the number for re-use.
remainingCapacity() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
Returns the number of elements that this queue can ideally (in the absence of memory or resource constraints) accept without blocking.
remove(Object) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
 
remove(T) - Method in class com.rabbitmq.client.impl.SetQueue
Remove item from queue, if present.
removeBlockedListener(BlockedListener) - Method in interface com.rabbitmq.client.Connection
Remove a BlockedListener.
removeBlockedListener(BlockedListener) - Method in class com.rabbitmq.client.impl.AMQConnection
 
removeBlockedListener(BlockedListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
removeConfirmListener(ConfirmListener) - Method in interface com.rabbitmq.client.Channel
Remove a ConfirmListener.
removeConfirmListener(ConfirmListener) - Method in class com.rabbitmq.client.impl.ChannelN
 
removeConfirmListener(ConfirmListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
removeConsumerRecoveryListener(ConsumerRecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
removeQueueRecoveryListener(QueueRecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
removeRecoveryCanBeginListener(RecoveryCanBeginListener) - Method in class com.rabbitmq.client.impl.AMQConnection
 
removeRecoveryListener(RecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
removeRecoveryListener(RecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
Removes the recovery listener
removeRecoveryListener(RecoveryListener) - Method in interface com.rabbitmq.client.Recoverable
 
removeReturnListener(ReturnListener) - Method in interface com.rabbitmq.client.Channel
Remove a ReturnListener.
removeReturnListener(ReturnListener) - Method in class com.rabbitmq.client.impl.ChannelN
 
removeReturnListener(ReturnListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
removeShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
removeShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
 
removeShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
 
removeShutdownListener(ShutdownListener) - Method in interface com.rabbitmq.client.ShutdownNotifier
Remove shutdown listener for the component.
REPLY_SUCCESS - Static variable in interface com.rabbitmq.client.AMQP
 
replyCode(int) - Method in class com.rabbitmq.client.AMQP.Basic.Return.Builder
 
replyCode(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
 
replyCode(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
 
replyText(String) - Method in class com.rabbitmq.client.AMQP.Basic.Return.Builder
 
replyText(String) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
 
replyText(String) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
 
replyTo(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
 
request - Variable in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
 
Request(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
Request(String, boolean, boolean, boolean, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Access.Request
 
RequestOk(int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
 
RequestOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
 
requeue() - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
 
requeue() - Method in class com.rabbitmq.client.AMQP.Basic.Recover.Builder
 
requeue() - Method in class com.rabbitmq.client.AMQP.Basic.RecoverAsync.Builder
 
requeue() - Method in class com.rabbitmq.client.AMQP.Basic.Reject.Builder
 
requeue(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
 
requeue(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Recover.Builder
 
requeue(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.RecoverAsync.Builder
 
requeue(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Reject.Builder
 
reserve(int) - Method in class com.rabbitmq.utility.IntAllocator
Attempt to reserve the provided ID as if it had been allocated.
reset() - Method in class com.rabbitmq.client.impl.TruncatedInputStream
 
resolveIpAddresses(String) - Method in class com.rabbitmq.client.DnsRecordIpAddressResolver
 
RESOURCE_ERROR - Static variable in interface com.rabbitmq.client.AMQP
 
RESOURCE_LOCKED - Static variable in interface com.rabbitmq.client.AMQP
 
response(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.SecureOk.Builder
 
response(LongString) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
 
response(Object, String, Object) - Static method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
Private API - used by errorResponse and resultResponse.
response(String) - Method in class com.rabbitmq.client.AMQP.Connection.SecureOk.Builder
 
response(String) - Method in class com.rabbitmq.client.AMQP.Connection.StartOk.Builder
 
Response() - Constructor for class com.rabbitmq.client.RpcClient.Response
 
Response(String, Envelope, AMQP.BasicProperties, byte[]) - Constructor for class com.rabbitmq.client.RpcClient.Response
 
responseCall(byte[]) - Method in class com.rabbitmq.client.RpcClient
Perform a simple byte-array-based RPC roundtrip Useful if you need to get at more than just the body of the message
resultResponse(Object, Object) - Static method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
Construct and encode a JSON-RPC success response for the request ID given, using the result value passed in.
Return - Class in com.rabbitmq.client
 
Return(int, String, String, String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
Return(int, String, String, String, AMQP.BasicProperties, byte[]) - Constructor for class com.rabbitmq.client.Return
 
Return(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Return
 
ReturnCallback - Interface in com.rabbitmq.client
Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.
ReturnListener - Interface in com.rabbitmq.client
Implement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set.
REVISION - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
 
Rollback() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
 
Rollback(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
 
RollbackOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
 
RollbackOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
 
routingKey - Variable in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Basic.Deliver.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Basic.GetOk.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Basic.Return.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
 
routingKey(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
rpc(Method) - Method in interface com.rabbitmq.client.Channel
Synchronously send a method over this channel.
rpc(Method) - Method in class com.rabbitmq.client.impl.AMQChannel
Protected API - sends a Method to the broker and waits for the next in-bound Command from the broker: only for use from non-connection-MainLoop threads!
rpc(Method) - Method in class com.rabbitmq.client.impl.ChannelN
 
rpc(Method) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
rpc(Method, int) - Method in class com.rabbitmq.client.impl.AMQChannel
 
rpc(Method, AMQChannel.RpcContinuation) - Method in class com.rabbitmq.client.impl.AMQChannel
 
RpcClient - Class in com.rabbitmq.client
Convenience class which manages simple RPC-style communication.
RpcClient(Channel, String, String) - Constructor for class com.rabbitmq.client.RpcClient
Construct a new RpcClient that will communicate on the given channel, sending requests to the given exchange with the given routing key.
RpcClient(Channel, String, String, int) - Constructor for class com.rabbitmq.client.RpcClient
Construct a new RpcClient that will communicate on the given channel, sending requests to the given exchange with the given routing key.
RpcClient(Channel, String, String, String) - Constructor for class com.rabbitmq.client.RpcClient
Construct a new RpcClient that will communicate on the given channel, sending requests to the given exchange with the given routing key.
RpcClient(Channel, String, String, String, int) - Constructor for class com.rabbitmq.client.RpcClient
Construct a new RpcClient that will communicate on the given channel, sending requests to the given exchange with the given routing key.
RpcClient.Response - Class in com.rabbitmq.client
The response object is an envelope that contains all of the data provided to the `handleDelivery` consumer
RpcContinuationRpcWrapper - Class in com.rabbitmq.client.impl
 
RpcContinuationRpcWrapper(AMQChannel.RpcContinuation) - Constructor for class com.rabbitmq.client.impl.RpcContinuationRpcWrapper
 
RpcServer - Class in com.rabbitmq.client
Class which manages a request queue for a simple RPC-style service.
RpcServer(Channel) - Constructor for class com.rabbitmq.client.RpcServer
Creates an RpcServer listening on a temporary exclusive autodelete queue.
RpcServer(Channel, String) - Constructor for class com.rabbitmq.client.RpcServer
If the passed-in queue name is null, creates a server-named temporary exclusive autodelete queue to use; otherwise expects the queue to have already been declared.
RpcServer.RpcConsumer - Interface in com.rabbitmq.client
 
RpcWrapper - Interface in com.rabbitmq.client.impl
 
run() - Method in class com.rabbitmq.client.impl.nio.NioLoop
 

S

SaslConfig - Interface in com.rabbitmq.client
This interface represents a hook to allow you to control how exactly a sasl client is selected during authentication.
SaslMechanism - Interface in com.rabbitmq.client
Our own view of a SASL authentication mechanism, introduced to remove a dependency on javax.security.sasl.
Secure(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
 
Secure(LongString) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
 
SecureOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
 
SecureOk(LongString) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
 
Select() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.Select
 
Select(boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
 
Select(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
 
Select(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.Select
 
SelectOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
 
SelectOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
 
SelectOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
 
SelectOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
 
SelectorHolder - Class in com.rabbitmq.client.impl.nio
 
sendHeader() - Method in interface com.rabbitmq.client.impl.FrameHandler
Send the initial connection header, thus kickstarting the AMQP protocol version negotiation process and putting the underlying connection in a state such that the next layer of startup can proceed.
sendHeader() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandler
 
sendHeader() - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
 
sendHeader() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
 
sendHeader(int, int) - Method in class com.rabbitmq.client.impl.SocketFrameHandler
Write a 0-8-style connection header to the underlying socket, containing the specified version information, kickstarting the AMQP protocol version negotiation process.
sendHeader(int, int, int) - Method in class com.rabbitmq.client.impl.SocketFrameHandler
Write a 0-9-1-style connection header to the underlying socket, containing the specified version information, kickstarting the AMQP protocol version negotiation process.
sensibleClone() - Method in exception com.rabbitmq.client.ConsumerCancelledException
 
sensibleClone() - Method in exception com.rabbitmq.client.ShutdownSignalException
 
sensibleClone() - Method in interface com.rabbitmq.utility.SensibleClone
Like Object.clone but sensible; in particular, public and declared to return the right type.
SensibleClone<T extends SensibleClone<T>> - Interface in com.rabbitmq.utility
This interface exists as a workaround for the annoyingness of java.lang.Cloneable.
serverNamed(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue
 
serverProperties(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
 
serviceDescription - Variable in class com.rabbitmq.tools.jsonrpc.JsonRpcServer
Holds the JSON-RPC service description for this client.
ServiceDescription - Class in com.rabbitmq.tools.jsonrpc
Description of a JSON-RPC service.
ServiceDescription() - Constructor for class com.rabbitmq.tools.jsonrpc.ServiceDescription
 
ServiceDescription(Class<?>) - Constructor for class com.rabbitmq.tools.jsonrpc.ServiceDescription
 
ServiceDescription(Map<String, Object>) - Constructor for class com.rabbitmq.tools.jsonrpc.ServiceDescription
 
set(T) - Method in class com.rabbitmq.utility.BlockingCell
Store a value in this BlockingCell, throwing IllegalStateException if the cell already has a value.
setAutomaticRecoveryEnabled(boolean) - Method in class com.rabbitmq.client.ConnectionFactory
Enables or disables automatic connection recovery.
setCapacity(int) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
Set a new capacity for the queue.
setChannelRpcTimeout(int) - Method in class com.rabbitmq.client.ConnectionFactory
Set the continuation timeout for RPC calls in channels.
setChannelRpcTimeout(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
 
setChannelShouldCheckRpcResponseType(boolean) - Method in class com.rabbitmq.client.ConnectionFactory
When set to true, channels will check the response type (e.g.
setChannelShouldCheckRpcResponseType(boolean) - Method in class com.rabbitmq.client.impl.ConnectionParams
 
setChannelShutdownTimeout(int) - Method in class com.rabbitmq.client.impl.ChannelManager
Set the shutdown timeout for channels.
setClientProperties(Map<String, Object>) - Method in class com.rabbitmq.client.ConnectionFactory
Replace the table of client properties that will be sent to the server during subsequent connection startups.
setClientProperties(Map<String, Object>) - Method in class com.rabbitmq.client.impl.ConnectionParams
 
setConnection(AMQConnection) - Method in class com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
 
setConnectionTimeout(int) - Method in class com.rabbitmq.client.ConnectionFactory
Set the TCP connection timeout.
setConsumerWorkServiceExecutor(ExecutorService) - Method in class com.rabbitmq.client.impl.ConnectionParams
 
setDefaultConsumer(Consumer) - Method in interface com.rabbitmq.client.Channel
Set the current default consumer.
setDefaultConsumer(Consumer) - Method in class com.rabbitmq.client.impl.ChannelN
Sets the current default consumer.
setDefaultConsumer(Consumer) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
 
setDestination(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
 
setException(E) - Method in class com.rabbitmq.utility.BlockingValueOrException
 
setExceptionHandler(ExceptionHandler) - Method in class com.rabbitmq.client.ConnectionFactory
<