Index

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

A

abort() - Method in interface com.rabbitmq.client.Channel

Abort this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.

abort() - Method in interface com.rabbitmq.client.Connection

Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.

abort() - Method in class com.rabbitmq.client.impl.AMQConnection

Public API - Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.

abort() - Method in class com.rabbitmq.client.impl.ChannelN

Public API - Abort this channel with the AMQP.REPLY_SUCCESS close code and message 'OK'.

abort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

abort() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

abort(int) - Method in interface com.rabbitmq.client.Connection

Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.

abort(int) - Method in class com.rabbitmq.client.impl.AMQConnection

Public API - Abort this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.

abort(int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

abort(int, String) - Method in interface com.rabbitmq.client.Channel

Abort this channel.

abort(int, String) - Method in interface com.rabbitmq.client.Connection

Abort this connection and all its channels.

abort(int, String) - Method in class com.rabbitmq.client.impl.AMQConnection

Public API - Abort this connection and all its channels.

abort(int, String) - Method in class com.rabbitmq.client.impl.ChannelN

Public API - Abort this channel.

abort(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

abort(int, String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

abort(int, String, int) - Method in interface com.rabbitmq.client.Connection

Abort this connection and all its channels.

abort(int, String, int) - Method in class com.rabbitmq.client.impl.AMQConnection

Public API - Abort this connection and all its channels.

abort(int, String, int) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

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

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(BlockedListener) - Method in interface com.rabbitmq.client.Connection

Add a BlockedListener.

addBlockedListener(BlockedListener) - Method in class com.rabbitmq.client.impl.AMQConnection

addBlockedListener(BlockedListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

addConfirmListener(ConfirmListener) - Method in interface com.rabbitmq.client.Channel

Add a ConfirmListener.

addConfirmListener(ConfirmListener) - Method in class com.rabbitmq.client.impl.ChannelN

addConfirmListener(ConfirmListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

addConsumerRecoveryListener(ConsumerRecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

Not part of the public API.

addFlowListener(FlowListener) - Method in interface com.rabbitmq.client.Channel

Deprecated.

addFlowListener(FlowListener) - Method in class com.rabbitmq.client.impl.ChannelN

Deprecated.

addFlowListener(FlowListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

Deprecated.

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.

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.

addReturnListener(ReturnListener) - Method in interface com.rabbitmq.client.Channel

Add a ReturnListener.

addReturnListener(ReturnListener) - Method in class com.rabbitmq.client.impl.ChannelN

addReturnListener(ReturnListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

addShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

addShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection

addShutdownListener(ShutdownListener) - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent

addShutdownListener(ShutdownListener) - Method in interface com.rabbitmq.client.ShutdownNotifier

Add shutdown listener.

addWork(Channel, Runnable) - Method in class com.rabbitmq.client.impl.ConsumerWorkService

addWorkItem(K, W) - Method in class com.rabbitmq.client.impl.WorkPool

Add (enqueue) an item for a specific client.

adjust() - Method in class com.rabbitmq.client.impl.Version

Adjust a version for spec weirdness.

allocate() - Method in class com.rabbitmq.utility.IntAllocator

Allocate an unallocated integer from the range, or return -1 if no more integers are available.

AlreadyClosedException - Exception Class in com.rabbitmq.client

Thrown when application tries to perform an action on connection/channel which was already closed

AlreadyClosedException(ShutdownSignalException) - Constructor for exception class com.rabbitmq.client.AlreadyClosedException

AlreadyClosedException(ShutdownSignalException, Throwable) - Constructor for exception class com.rabbitmq.client.AlreadyClosedException

AMQBasicProperties - Class in com.rabbitmq.client.impl

AMQBasicProperties() - Constructor for class com.rabbitmq.client.impl.AMQBasicProperties

AMQBasicProperties(DataInputStream) - Constructor for class com.rabbitmq.client.impl.AMQBasicProperties

AMQChannel - Class in com.rabbitmq.client.impl

Base class modelling an AMQ channel.

AMQChannel(AMQConnection, int) - Constructor for class com.rabbitmq.client.impl.AMQChannel

Construct a channel on the given connection, with the given channel number.

AMQChannel.BlockingRpcContinuation<T> - Class in com.rabbitmq.client.impl

AMQChannel.RpcContinuation - Interface in com.rabbitmq.client.impl

AMQChannel.SimpleBlockingRpcContinuation - Class in com.rabbitmq.client.impl

AMQCommand - Class in com.rabbitmq.client.impl

AMQ-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

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

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 wire-protocol length of an encoded field-array of type Listinvalid input: '<'?>

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.

AsyncLogger(OutputStream) - Constructor for class com.rabbitmq.tools.Tracer.AsyncLogger

Same as

invalid @link

{@link #Tracer.AsyncLogger(OutputStream, int)

} with a one-second flush interval.

AsyncLogger(OutputStream, int) - Constructor for class com.rabbitmq.tools.Tracer.AsyncLogger

Start/stoppable logger that prints to an OutputStream with flushes every flushInterval milliseconds.

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

AuthenticationFailureException - Exception Class in com.rabbitmq.client

Thrown when the broker refuses access due to an authentication failure.

AuthenticationFailureException(String) - Constructor for exception class com.rabbitmq.client.AuthenticationFailureException

autoAck(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer

autoDelete() - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder

autoDelete() - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder

autoDelete(boolean) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder

autoDelete(boolean) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder

autoDelete(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange

autoDelete(boolean) - Method in class com.rabbitmq.client.impl.recovery.RecordedQueue

automaticallyRecover(AutorecoveringConnection, Connection) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

AutorecoveringChannel - Class in com.rabbitmq.client.impl.recovery

Channel implementation that is automatically recovered during connection recovery.

AutorecoveringChannel(AutorecoveringConnection, RecoveryAwareChannelN) - Constructor for class com.rabbitmq.client.impl.recovery.AutorecoveringChannel

AutorecoveringConnection - Class in com.rabbitmq.client.impl.recovery

Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.

AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, 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
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(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, 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, 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, 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, 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
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
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(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
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
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
BlockingValueOrException<V,E> - Class in com.rabbitmq.utility
BlockingValueOrException() - Constructor for class com.rabbitmq.utility.BlockingValueOrException
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

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() - Method in class com.rabbitmq.utility.SingleShotLinearTimer
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
CancelOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
CancelOk(String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
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.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
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
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.
checkClientTrusted(X509Certificate[], String) - Method in class com.rabbitmq.client.NullTrustManager: Deprecated.

Trusts any client certificate: no verification is performed.
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.NullTrustManager: Deprecated.

Trusts any server certificate: no verification is performed.
checkVersion(Version, Version) - Static method in class com.rabbitmq.client.impl.Version: Check compatibility of a client and server version, from the client's perspective.
classId - Variable in exception class com.rabbitmq.client.UnknownClassOrMethodId
classId(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
classId(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
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
clearFlowListeners() - Method in interface com.rabbitmq.client.Channel: Deprecated.
clearFlowListeners() - Method in class com.rabbitmq.client.impl.ChannelN: Deprecated.
clearFlowListeners() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel: Deprecated.
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
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.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(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
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 class 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
com.rabbitmq.client.impl - package com.rabbitmq.client.impl
com.rabbitmq.client.impl.recovery - package com.rabbitmq.client.impl.recovery
com.rabbitmq.client.test.ssl - package com.rabbitmq.client.test.ssl
com.rabbitmq.tools - package com.rabbitmq.tools
com.rabbitmq.tools.json - package com.rabbitmq.tools.json
com.rabbitmq.tools.jsonrpc - package com.rabbitmq.tools.jsonrpc
com.rabbitmq.utility - package com.rabbitmq.utility
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
computeDefaultTlsProcotol(String[]) - Static method in class com.rabbitmq.client.ConnectionFactory
Concurrency Considerations - Search tag in interface com.rabbitmq.client.Channel: Section
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.
Confirm() - Constructor for class com.rabbitmq.client.AMQP.Confirm
Confirm() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Confirm
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_FORCED - Static variable in interface com.rabbitmq.client.AMQP
ConnectionFactory - Class in com.rabbitmq.client: Convenience "factory" class to facilitate opening a Connection to an AMQP broker.
ConnectionFactory() - Constructor for class com.rabbitmq.client.ConnectionFactory
ConnectionFactoryDefaultTlsVersion - Class in com.rabbitmq.client.test.ssl
ConnectionFactoryDefaultTlsVersion() - Constructor for class com.rabbitmq.client.test.ssl.ConnectionFactoryDefaultTlsVersion
ConnectionParams - Class in com.rabbitmq.client.impl
ConnectionParams() - Constructor for class com.rabbitmq.client.impl.ConnectionParams
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
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 Class in com.rabbitmq.client
ConsumerCancelledException() - Constructor for exception class com.rabbitmq.client.ConsumerCancelledException
consumerCount(int) - Method in class com.rabbitmq.client.AMQP.Queue.DeclareOk.Builder
consumerCount(String) - Method in interface com.rabbitmq.client.Channel: Returns the number of consumers on a queue.
consumerCount(String) - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Returns the number of consumers on a queue.
consumerCount(String) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
consumerRecovered(String, String) - Method in interface com.rabbitmq.client.impl.recovery.ConsumerRecoveryListener
ConsumerRecoveryListener - Interface in com.rabbitmq.client.impl.recovery: Not part of the public API.
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
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) - Method in class com.rabbitmq.client.impl.FrameHandlerFactory
create(Socket) - Method in class com.rabbitmq.client.impl.FrameHandlerFactory
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
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.

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
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_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_INBOUND_MESSAGE_BODY_SIZE - Static variable in class com.rabbitmq.client.ConnectionFactory: Default maximum body size of inbound messages: 64 MiB.
DEFAULT_PASS - Static variable in class com.rabbitmq.client.ConnectionFactory: Default password
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
DefaultSaslConfig - Class in com.rabbitmq.client: Default SASL configuration.
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
Delivery(Envelope, AMQP.BasicProperties, byte[]) - Constructor for class com.rabbitmq.client.QueueingConsumer.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
disconnectChannel(ChannelN) - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - respond, in the driver thread, to a ShutdownSignal.
doCall(String) - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Runs a single JSON-RPC request.
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
enableHostnameVerification() - Method in class com.rabbitmq.client.ConnectionFactory: Enables server hostname verification (TLS endpoint identification) for TLS connections created by this connection factory: the server certificate must be valid for the host the client connects to.
encode(Map<String, Object>) - Static method in class com.rabbitmq.client.MapRpcServer
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 - 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
equals(Object) - Method in class com.rabbitmq.client.Address
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 class 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, 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, 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
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
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

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
flowBlocked() - Method in interface com.rabbitmq.client.Channel: Deprecated.
flowBlocked() - Method in class com.rabbitmq.client.impl.ChannelN: Deprecated.
flowBlocked() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel: Deprecated.
FlowListener - Interface in com.rabbitmq.client: Implement this interface in order to be notified of Channel.Flow events.
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.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
FrameHandler - Interface in com.rabbitmq.client.impl: Interface to a frame handler.
FrameHandlerFactory - Class in com.rabbitmq.client.impl
FrameHandlerFactory(int, SocketFactory, SocketConfigurator, boolean) - Constructor for class com.rabbitmq.client.impl.FrameHandlerFactory: Deprecated.
use the constructor with an explicit inbound payload cap
FrameHandlerFactory(int, SocketFactory, SocketConfigurator, boolean, int) - Constructor for class com.rabbitmq.client.impl.FrameHandlerFactory
frameMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.Tune.Builder
frameMax(int) - Method in class com.rabbitmq.client.AMQP.Connection.TuneOk.Builder
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

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.NullTrustManager: Deprecated.
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.recovery.AutorecoveringConnection
getAddress() - Method in class com.rabbitmq.client.impl.SocketFrameHandler
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.GetResponse: Get the message body included in this response
getBody() - Method in class com.rabbitmq.client.QueueingConsumer.Delivery: Retrieve the message body.
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 class com.rabbitmq.client.DefaultConsumer: Retrieve the channel.
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 class com.rabbitmq.client.impl.AMQChannel: Public API - Retrieves this channel's channel number.
getChannelNumber() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getClassId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getClassId() - Method in interface com.rabbitmq.client.AMQP.Channel.Close
getClassId() - Method in interface com.rabbitmq.client.AMQP.Connection.Close
getClassId() - Method in interface com.rabbitmq.client.ContentHeader: Retrieve the class ID (see the spec for a list of allowable IDs).
getClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
getClassId() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
getClassName() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getClassName() - Method in interface com.rabbitmq.client.ContentHeader: Retrieve the class name, eg "basic" (see the spec for a list of these).
getClientMajor() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException: The client's AMQP specification major version.
getClientMinor() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException: The client's AMQP specification minor version.
getClientProperties() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
getClientProperties() - Method in interface com.rabbitmq.client.Connection: Get a copy of the map of client properties sent to the server
getClientProperties() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the currently-configured table of client properties that will be sent to the server during connection startup.
getClientProperties() - Method in class com.rabbitmq.client.impl.AMQConnection
getClientProperties() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
getClientProperties() - Method in class com.rabbitmq.client.impl.ConnectionParams
getClientProperties() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getClientProvidedName() - Method in interface com.rabbitmq.client.Connection: Returns client-provided connection name, if any.
getClientProvidedName() - Method in class com.rabbitmq.client.impl.AMQConnection
getClientProvidedName() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getClientVersion() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException: The client's AMQP specification version.
getCloseReason() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
getCloseReason() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getCloseReason() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
getCloseReason() - Method in interface com.rabbitmq.client.ShutdownNotifier: Get the shutdown reason object
getClusterId() - Method in interface com.rabbitmq.client.AMQP.Basic.GetEmpty
getClusterId() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getClusterId() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
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.recovery.AutorecoveringChannel
getConnectionTimeout() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the TCP connection timeout.
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
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
getDelegate() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
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.GetResponse: Get the Envelope included in this response
getEnvelope() - Method in class com.rabbitmq.client.QueueingConsumer.Delivery: Retrieve the message envelope.
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.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 class com.rabbitmq.client.UnexpectedFrameError
getExpiration() - Method in class com.rabbitmq.client.AMQP.BasicProperties
getExpiration() - Method in interface com.rabbitmq.client.BasicProperties: Retrieve the value in the expiration field.
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
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
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.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.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
getMaxInboundMessageBodySize() - Method in class com.rabbitmq.client.ConnectionFactory: Maximum body size of inbound (received) messages in bytes.
getMaxInboundMessageBodySize() - Method in class com.rabbitmq.client.impl.ConnectionParams
getMaxSeenDeliveryTag() - Method in class com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN
getMechanism() - Method in interface com.rabbitmq.client.AMQP.Connection.StartOk
getMechanism() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
getMechanisms() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getMechanisms() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
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 interface com.rabbitmq.client.Command: Retrieves the Method held within this Command.
getMethod() - Method in class com.rabbitmq.client.impl.AMQCommand: Public API - Retrieves the Method held within this Command.
getMethod() - Method in exception class com.rabbitmq.client.UnexpectedMethodError: Return the wrapped method.
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
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
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
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.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.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.
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.QueueingConsumer.Delivery: Retrieve the message properties.
getProps() - Method in class com.rabbitmq.client.GetResponse: Get the AMQP.BasicProperties included in this response
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
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 class com.rabbitmq.client.ShutdownSignalException
getReceivedFrame() - Method in exception class com.rabbitmq.client.UnexpectedFrameError
getRecordedExchanges() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getRecordedQueues() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getRedelivered() - Method in interface com.rabbitmq.client.AMQP.Basic.Deliver
getRedelivered() - Method in interface com.rabbitmq.client.AMQP.Basic.GetOk
getRedelivered() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
getRedelivered() - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
getReference() - Method in exception class com.rabbitmq.client.ShutdownSignalException
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
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
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.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 class com.rabbitmq.client.UnexpectedFrameError
getServerMajor() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException: The server's AMQP specification major version.
getServerMinor() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException: The server's AMQP specification minor version.
getServerProperties() - Method in interface com.rabbitmq.client.AMQP.Connection.Start
getServerProperties() - Method in interface com.rabbitmq.client.Connection: Retrieve the server properties.
getServerProperties() - Method in class com.rabbitmq.client.impl.AMQConnection: Retrieve the server properties.
getServerProperties() - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
getServerProperties() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
getServerVersion() - Method in exception class com.rabbitmq.client.ProtocolVersionMismatchException: The server's AMQP specification version.
getServiceDescription() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcClient: Public API - gets the service description record that this service loaded from the server itself at construction time.
getServiceDescription() - Method in class com.rabbitmq.tools.jsonrpc.JsonRpcServer: Public API - gets the service description record that this service built from interfaceClass at construction time.
getShutdownExecutor() - Method in class com.rabbitmq.client.impl.ChannelManager
getShutdownExecutor() - Method in class com.rabbitmq.client.impl.ConnectionParams
getShutdownTimeout() - Method in class com.rabbitmq.client.ConnectionFactory: Retrieve the shutdown timeout.
getShutdownTimeout() - Method in class com.rabbitmq.client.impl.ConnectionParams
getShutdownTimeout() - Method in class com.rabbitmq.client.impl.ConsumerWorkService
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
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
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.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 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
getWrite() - Method in interface com.rabbitmq.client.AMQP.Access.Request
getWrite() - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
global() - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder
global(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Qos.Builder

H

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(QueueingConsumer.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)
handleCancel(String) - Method in class com.rabbitmq.client.QueueingConsumer
handleCancelOk(String) - Method in interface com.rabbitmq.client.Consumer: Called when the consumer is cancelled by a call to Channel.basicCancel(java.lang.String).
handleCancelOk(String) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleCancelOk(java.lang.String).
handleCast(byte[]) - Method in class com.rabbitmq.client.MapRpcServer: Overridden to delegate to handleMapCast.
handleCast(byte[]) - Method in class com.rabbitmq.client.RpcServer: High-level handler method.
handleCast(byte[]) - Method in class com.rabbitmq.client.StringRpcServer: Overridden to do UTF-8 processing, and delegate to handleStringCast.
handleCast(AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.RpcServer: Mid-level handler method.
handleCast(QueueingConsumer.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: No-op implementation of Consumer.handleDelivery(java.lang.String, com.rabbitmq.client.Envelope, com.rabbitmq.client.AMQP.BasicProperties, byte[]).
handleDelivery(String, Envelope, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.client.QueueingConsumer
handleFlow(boolean) - Method in interface com.rabbitmq.client.FlowListener
handleFlowListenerException(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 FlowListener's handleFlow method, and that method has thrown an exception.
handleFlowListenerException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.ForgivingExceptionHandler
handleFlowListenerException(Channel, Throwable) - Method in class com.rabbitmq.client.impl.StrictExceptionHandler
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
handleMapCall(Map<String, Object>) - Method in class com.rabbitmq.client.MapRpcServer: Default implementation - override in subclasses.
handleMapCall(Map<String, Object>, AMQP.BasicProperties) - Method in class com.rabbitmq.client.MapRpcServer: Delegates to handleMapCall(Mapinvalid input: '<'String, Object>).
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
handleRecoverOk(String) - Method in interface com.rabbitmq.client.Consumer: Called when a basic.recover-ok is received in reply to a basic.recover.
handleRecoverOk(String) - Method in class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleRecoverOk(java.lang.String).
handleRecovery(Recoverable) - Method in interface com.rabbitmq.client.RecoveryListener
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 class com.rabbitmq.client.DefaultConsumer: No-op implementation of Consumer.handleShutdownSignal(java.lang.String, com.rabbitmq.client.ShutdownSignalException).
handleShutdownSignal(String, ShutdownSignalException) - Method in class com.rabbitmq.client.QueueingConsumer
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
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.recovery.RecordedBinding
hashCode() - Method in class com.rabbitmq.client.impl.Version
headers(Map<String, Object>) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
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
Historical Perspective - Search tag in class com.rabbitmq.client.QueueingConsumer: Section

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
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.
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.
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
isEmpty() - Method in class com.rabbitmq.client.impl.SetQueue
isHardError() - Method in exception class com.rabbitmq.client.ShutdownSignalException
isInitiatedByApplication() - Method in exception class com.rabbitmq.client.ShutdownSignalException
isOpen() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
isOpen() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
isOpen() - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent
isOpen() - Method in interface com.rabbitmq.client.ShutdownNotifier: Determine whether the component is currently open.
isOutstandingRpc() - Method in class com.rabbitmq.client.impl.AMQChannel
isRedeliver() - Method in class com.rabbitmq.client.Envelope: Get the redelivery flag included in this parameter envelope.
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 Class in com.rabbitmq.tools.jsonrpc: Thrown when a JSON-RPC service indicates an error occurred during a call.
JsonRpcException() - Constructor for exception class com.rabbitmq.tools.jsonrpc.JsonRpcException
JsonRpcException(Map<String, Object>) - Constructor for exception class 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
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) - Method in class com.rabbitmq.tools.Tracer.AsyncLogger
log(String) - Method in class com.rabbitmq.tools.Tracer
log(String) - Method in interface com.rabbitmq.tools.Tracer.Logger: Write msg to the log.
logException(Exception) - Method in class com.rabbitmq.tools.Tracer
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

M

main(String[]) - Static method in class com.rabbitmq.tools.Tracer
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
makeValue(V) - Static method in class com.rabbitmq.utility.ValueOrException: Factory method for values
MalformedFrameException - Exception Class in com.rabbitmq.client: Encapsulates a frame format error at the wire level.
MalformedFrameException(String) - Constructor for exception class com.rabbitmq.client.MalformedFrameException: Instantiate a MalformedFrameException.
mandatory() - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
mandatory(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
mapCall(Object[]) - Method in class com.rabbitmq.client.RpcClient: Perform an AMQP wire-protocol-table based RPC roundtrip, first constructing the table from an array of alternating keys (in even-numbered elements, starting at zero) and values (in odd-numbered elements, starting at one)
Restrictions on value arguments apply as in RpcClient.mapCall(Map).
mapCall(Map<String, Object>) - Method in class com.rabbitmq.client.RpcClient: Perform an AMQP wire-protocol-table based RPC roundtrip

There are some restrictions on the values appearing in the table:
they must be of type String, LongString, Integer, BigDecimal, Date, or (recursively) a Map of the enclosing type.
MapRpcServer - Class in com.rabbitmq.client: Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies.
MapRpcServer(Channel) - Constructor for class com.rabbitmq.client.MapRpcServer
MapRpcServer(Channel, String) - Constructor for class com.rabbitmq.client.MapRpcServer
mark(int) - Method in class com.rabbitmq.client.impl.TruncatedInputStream
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 class 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 method - see the spec for details.
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 class com.rabbitmq.client.UnknownClassOrMethodId
methodId(int) - Method in class com.rabbitmq.client.AMQP.Channel.Close.Builder
methodId(int) - Method in class com.rabbitmq.client.AMQP.Connection.Close.Builder
MINIMAL_BASIC - Static variable in class com.rabbitmq.client.MessageProperties: Empty basic properties, with no fields set
MINIMAL_PERSISTENT_BASIC - Static variable in class com.rabbitmq.client.MessageProperties: Empty basic properties, with only deliveryMode set to 2 (persistent)
MINOR - Static variable in class com.rabbitmq.client.AMQP.PROTOCOL
MissedHeartbeatException - Exception Class in com.rabbitmq.client: Encapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down.
MissedHeartbeatException(String) - Constructor for exception class com.rabbitmq.client.MissedHeartbeatException
multiple() - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
multiple() - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder
multiple(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Ack.Builder
multiple(boolean) - Method in class com.rabbitmq.client.AMQP.Basic.Nack.Builder

N

Nack(long, boolean, boolean) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
Nack(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
name - Variable in class com.rabbitmq.client.impl.recovery.RecordedNamedEntity
name - Variable in exception class 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
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
newConnection() - Method in class com.rabbitmq.client.ConnectionFactory: Create a new broker connection.
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(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, 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.
nextDelivery() - Method in class com.rabbitmq.client.QueueingConsumer: Main application-side API: wait for the next message delivery and return it.
nextDelivery(long) - Method in class com.rabbitmq.client.QueueingConsumer: Main application-side API: wait for the next message delivery and return it.
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.
NO_CONSUMERS - Static variable in interface com.rabbitmq.client.AMQP
NO_ROUTE - Static variable in interface com.rabbitmq.client.AMQP
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
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
NullTrustManager - Class in com.rabbitmq.client: Deprecated.
NullTrustManager() - Constructor for class com.rabbitmq.client.NullTrustManager: Deprecated.

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
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
portOrDefault(int, boolean) - Static method in class com.rabbitmq.client.ConnectionFactory
PossibleAuthenticationFailureException - Exception Class in com.rabbitmq.client: Thrown when the likely cause is an authentication failure.
PossibleAuthenticationFailureException(String) - Constructor for exception class com.rabbitmq.client.PossibleAuthenticationFailureException
PossibleAuthenticationFailureException(Throwable) - Constructor for exception class com.rabbitmq.client.PossibleAuthenticationFailureException
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
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(QueueingConsumer.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.
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 Class 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 class 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
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.queueDeclare(String, boolean, boolean, boolean, 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.queueDeclare(String, boolean, boolean, boolean, 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
QueueingConsumer - Class in com.rabbitmq.client: Convenience class: an implementation of Consumer with straightforward blocking semantics.
QueueingConsumer(Channel) - Constructor for class com.rabbitmq.client.QueueingConsumer
QueueingConsumer(Channel, BlockingQueue<QueueingConsumer.Delivery>) - Constructor for class com.rabbitmq.client.QueueingConsumer
QueueingConsumer.Delivery - Class in com.rabbitmq.client: Encapsulates an arbitrary message - simple "bean" holder structure.
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
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.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.
readFrom(DataInputStream, int) - 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, rejecting payloads larger than the configured maximum.
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.
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
RecoveryAwareAMQConnectionFactory - Class in com.rabbitmq.client.impl.recovery
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
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.
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
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
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
removeFlowListener(FlowListener) - Method in interface com.rabbitmq.client.Channel: Deprecated.
removeFlowListener(FlowListener) - Method in class com.rabbitmq.client.impl.ChannelN: Deprecated.
removeFlowListener(FlowListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel: Deprecated.
removeQueueRecoveryListener(QueueRecoveryListener) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
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(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
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
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(int, String, String, String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Return
Return(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Basic.Return
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.
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.
run() - Method in class com.rabbitmq.tools.Tracer

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.
schedule(Runnable, int) - Method in class com.rabbitmq.utility.SingleShotLinearTimer
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
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.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 class com.rabbitmq.client.ConsumerCancelledException
sensibleClone() - Method in exception class 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> - 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 AssertionError 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.
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
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: Set the exception handler to use for newly created connections.
setExceptionHandler(ExceptionHandler) - Method in class com.rabbitmq.client.impl.ConnectionParams
setHandshakeTimeout(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the AMQP0-9-1 protocol handshake timeout.
setHandshakeTimeout(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
setHeartbeat(int) - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - set the heartbeat timeout.
setHeartbeatExecutor(ScheduledExecutorService) - Method in class com.rabbitmq.client.ConnectionFactory: Set the executor to use to send heartbeat frames.
setHeartbeatExecutor(ScheduledExecutorService) - Method in class com.rabbitmq.client.impl.ConnectionParams
setHost(String) - Method in class com.rabbitmq.client.ConnectionFactory
setIfUnset(T) - Method in class com.rabbitmq.utility.BlockingCell: Store a value in this BlockingCell if it doesn't already have a value.
setIndentMode(boolean) - Method in class com.rabbitmq.tools.json.JSONWriter
setMaxInboundFramePayloadSize(int) - Method in class com.rabbitmq.client.impl.SocketFrameHandler: Cap inbound frame payloads, applied once frame_max is negotiated.
setMaxInboundMessageBodySize(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the maximum body size of inbound (received) messages in bytes; larger messages are rejected with an exception instead of being allocated, to avoid running out of memory.
setMaxInboundMessageBodySize(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
setNetworkRecoveryInterval(int) - Method in class com.rabbitmq.client.ConnectionFactory: Sets connection recovery interval.
setNetworkRecoveryInterval(long) - Method in class com.rabbitmq.client.ConnectionFactory: Sets connection recovery interval.
setNetworkRecoveryInterval(long) - Method in class com.rabbitmq.client.impl.ConnectionParams
setPassword(String) - Method in class com.rabbitmq.client.ConnectionFactory: Set the password.
setPassword(String) - Method in class com.rabbitmq.client.impl.ConnectionParams
setPort(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the target port.
setProcs(Collection<Map<String, Object>>) - Method in class com.rabbitmq.tools.jsonrpc.ServiceDescription: Private API - used via reflection during parsing/loading
setQueue(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedConsumer
SetQueue<T> - Class in com.rabbitmq.client.impl: A generic queue-like implementation (supporting operations addIfNotPresent, poll, contains, and isEmpty) which restricts a queue element to appear at most once.
SetQueue() - Constructor for class com.rabbitmq.client.impl.SetQueue
setRequestedChannelMax(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the requested maximum channel number
setRequestedChannelMax(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
setRequestedFrameMax(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the requested maximum frame size
setRequestedFrameMax(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
setRequestedHeartbeat(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the requested heartbeat timeout.
setRequestedHeartbeat(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
setReturn(String) - Method in class com.rabbitmq.tools.jsonrpc.ProcedureDescription: Private API - used via reflection during parsing/loading
setSaslConfig(SaslConfig) - Method in class com.rabbitmq.client.ConnectionFactory: Sets the sasl config to use when authenticating
setSaslConfig(SaslConfig) - Method in class com.rabbitmq.client.impl.ConnectionParams
setSharedExecutor(ExecutorService) - Method in class com.rabbitmq.client.ConnectionFactory: Set the executor to use for consumer operation dispatch by default for newly created connections.
setShutdownCauseIfOpen(ShutdownSignalException) - Method in class com.rabbitmq.client.impl.ShutdownNotifierComponent: Internal: this is the means of registering shutdown.
setShutdownExecutor(ExecutorService) - Method in class com.rabbitmq.client.ConnectionFactory: Set the executor to use for connection shutdown.
setShutdownExecutor(ExecutorService) - Method in class com.rabbitmq.client.impl.ChannelManager
setShutdownExecutor(ExecutorService) - Method in class com.rabbitmq.client.impl.ConnectionParams
setShutdownTimeout(int) - Method in class com.rabbitmq.client.ConnectionFactory: Set the shutdown timeout.
setShutdownTimeout(int) - Method in class com.rabbitmq.client.impl.ConnectionParams
setSocketConfigurator(SocketConfigurator) - Method in class com.rabbitmq.client.ConnectionFactory: Set the socket configurator.
setSocketFactory(SocketFactory) - Method in class com.rabbitmq.client.ConnectionFactory: Set the socket factory used to make connections with.
setThreadFactory(ThreadFactory) - Method in class com.rabbitmq.client.ConnectionFactory: Set the thread factory used to instantiate new threads.
setThreadFactory(ThreadFactory) - Method in class com.rabbitmq.client.impl.AMQConnection: Makes it possible to override thread factory that is used to instantiate connection network I/O loop.
setThreadFactory(ThreadFactory) - Method in class com.rabbitmq.client.impl.ConnectionParams
setTimeout(int) - Method in interface com.rabbitmq.client.impl.FrameHandler: Set the underlying socket's read timeout in milliseconds, if applicable.
setTimeout(int) - Method in class com.rabbitmq.client.impl.SocketFrameHandler
setTopologyRecovery(boolean) - Method in class com.rabbitmq.client.impl.ConnectionParams
setTopologyRecoveryEnabled(boolean) - Method in class com.rabbitmq.client.ConnectionFactory: Enables or disables topology recovery
setUnlimited(Channel, boolean) - Method in class com.rabbitmq.client.impl.ConsumerWorkService
setupConsumer() - Method in class com.rabbitmq.client.RpcClient: Registers a consumer on the reply queue.
setupConsumer() - Method in class com.rabbitmq.client.RpcServer: Registers a consumer on the reply queue.
setUri(String) - Method in class com.rabbitmq.client.ConnectionFactory: Convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host.
setUri(URI) - Method in class com.rabbitmq.client.ConnectionFactory: Convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host.
setUsername(String) - Method in class com.rabbitmq.client.ConnectionFactory: Set the user name.
setUsername(String) - Method in class com.rabbitmq.client.impl.ConnectionParams
setValue(V) - Method in class com.rabbitmq.utility.BlockingValueOrException
setVirtualHost(String) - Method in class com.rabbitmq.client.ConnectionFactory: Set the virtual host.
setVirtualHost(String) - Method in class com.rabbitmq.client.impl.ConnectionParams
shouldTriggerConnectionRecovery(ShutdownSignalException) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
shutdown() - Method in class com.rabbitmq.client.impl.ConsumerWorkService: Stop executing all consumer work
shutdown(Method, boolean, Throwable, boolean) - Method in class com.rabbitmq.client.impl.AMQConnection: Protected API - causes all attached channels to terminate (shutdown) with a ShutdownSignal built from the argument, and stops this connection from accepting further work from the application.
shutdownCompleted(ShutdownSignalException) - Method in interface com.rabbitmq.client.ShutdownListener
ShutdownListener - Interface in com.rabbitmq.client: A ShutdownListener receives information about the shutdown of connections and channels.
ShutdownNotifier - Interface in com.rabbitmq.client: Interface for components that are shutdown capable and that allow listeners to be added for shutdown signals
ShutdownNotifierComponent - Class in com.rabbitmq.client.impl: A class that manages ShutdownListeners and remembers the reason for a shutdown.
ShutdownNotifierComponent() - Constructor for class com.rabbitmq.client.impl.ShutdownNotifierComponent
ShutdownSignalException - Exception Class in com.rabbitmq.client: Encapsulates a shutdown condition for a connection to an AMQP broker.
ShutdownSignalException(boolean, boolean, Method, Object) - Constructor for exception class com.rabbitmq.client.ShutdownSignalException: Construct a ShutdownSignalException from the arguments.
ShutdownSignalException(boolean, boolean, Method, Object, String, Throwable) - Constructor for exception class com.rabbitmq.client.ShutdownSignalException: Construct a ShutdownSignalException from the arguments.
SimpleBlockingRpcContinuation() - Constructor for class com.rabbitmq.client.impl.AMQChannel.SimpleBlockingRpcContinuation
SingleShotLinearTimer - Class in com.rabbitmq.utility: This class provides a very stripped-down clone of some of the functionality in java.util.Timer (notably Timer.schedule(TimerTask task, long delay) but uses System.nanoTime() rather than System.currentTimeMillis() as a measure of the underlying time, and thus behaves correctly if the system clock jumps around.
SingleShotLinearTimer() - Constructor for class com.rabbitmq.utility.SingleShotLinearTimer
size() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Returns the number of elements in this queue.
skip(long) - Method in class com.rabbitmq.client.impl.TruncatedInputStream
SOCKET_CLOSING_TIMEOUT - Static variable in class com.rabbitmq.client.impl.SocketFrameHandler: Time to linger before closing the socket forcefully.
SocketConfigurator - Interface in com.rabbitmq.client
SocketFrameHandler - Class in com.rabbitmq.client.impl: A socket-based frame handler.
SocketFrameHandler(Socket) - Constructor for class com.rabbitmq.client.impl.SocketFrameHandler
SocketFrameHandler(Socket, int) - Constructor for class com.rabbitmq.client.impl.SocketFrameHandler
source - Variable in class com.rabbitmq.client.impl.recovery.RecordedBinding
source(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
source(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
source(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedBinding
start() - Method in class com.rabbitmq.client.impl.AMQConnection: Start up the connection, including the MainLoop thread.
start() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
start() - Method in class com.rabbitmq.tools.Tracer.AsyncLogger
start() - Method in interface com.rabbitmq.tools.Tracer.Logger: Start logging, that is, printing log entries written using Tracer.Logger.log(String).
start() - Method in class com.rabbitmq.tools.Tracer
Start(int, int, Map<String, Object>, LongString, LongString) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Start
Start(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Start
StartOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
StartOk(Map<String, Object>, String, LongString, String) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
stop() - Method in class com.rabbitmq.tools.Tracer.AsyncLogger
stop() - Method in interface com.rabbitmq.tools.Tracer.Logger: Stop logging, that is, stop printing log entries written using Tracer.Logger.log(String).
stopWork(Channel) - Method in class com.rabbitmq.client.impl.ConsumerWorkService: Stop executing all consumer work for a particular channel
StrictExceptionHandler - Class in com.rabbitmq.client.impl: An implementation of ExceptionHandler that does close channels on unhandled consumer exception.
StrictExceptionHandler() - Constructor for class com.rabbitmq.client.impl.StrictExceptionHandler
STRING_ENCODING - Static variable in class com.rabbitmq.client.StringRpcServer
stringCall(String) - Method in class com.rabbitmq.client.RpcClient: Perform a simple string-based RPC roundtrip.
StringRpcServer - Class in com.rabbitmq.client: Subclass of RpcServer which accepts UTF-8 string requests.
StringRpcServer(Channel) - Constructor for class com.rabbitmq.client.StringRpcServer
StringRpcServer(Channel, String) - Constructor for class com.rabbitmq.client.StringRpcServer
summary - Variable in class com.rabbitmq.tools.jsonrpc.ProcedureDescription: Human-readable procedure summary
summary - Variable in class com.rabbitmq.tools.jsonrpc.ServiceDescription: Human-readable summary for the service
SYNTAX_ERROR - Static variable in interface com.rabbitmq.client.AMQP

T

tableSize(Map<String, Object>) - Static method in class com.rabbitmq.client.impl.Frame: Computes the AMQP wire-protocol length of protocol-encoded table entries.
take() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
terminateMainloop() - Method in class com.rabbitmq.client.RpcServer: Call this method to terminate the mainloop.
testDefaultTlsVersionJdk16ShouldTakeFallback() - Method in class com.rabbitmq.client.test.ssl.ConnectionFactoryDefaultTlsVersion
testDefaultTlsVersionJdk17ShouldTakePrefered() - Method in class com.rabbitmq.client.test.ssl.ConnectionFactoryDefaultTlsVersion
testDefaultTlsVersionJdk18ShouldTakePrefered() - Method in class com.rabbitmq.client.test.ssl.ConnectionFactoryDefaultTlsVersion
TEXT_PLAIN - Static variable in class com.rabbitmq.client.MessageProperties: Content-type "text/plain", deliveryMode 1 (nonpersistent), priority zero
ticket(int) - Method in class com.rabbitmq.client.AMQP.Access.RequestOk.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Basic.Consume.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Basic.Get.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Basic.Publish.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Exchange.Bind.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Exchange.Delete.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Exchange.Unbind.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Queue.Bind.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Queue.Declare.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Queue.Delete.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Queue.Purge.Builder
ticket(int) - Method in class com.rabbitmq.client.AMQP.Queue.Unbind.Builder
timestamp(Date) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
toArray() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
toArray(T[]) - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
toFrame(int) - Method in class com.rabbitmq.client.impl.Method
toFrame(int, long) - Method in class com.rabbitmq.client.impl.AMQContentHeader: Private API - Called by AMQCommand.transmit(com.rabbitmq.client.impl.AMQChannel)
TopologyRecoveryException - Exception Class in com.rabbitmq.client: Indicates an exception thrown during topology recovery.
TopologyRecoveryException(String, Throwable) - Constructor for exception class com.rabbitmq.client.TopologyRecoveryException
toString() - Method in class com.rabbitmq.client.Address
toString() - Method in class com.rabbitmq.client.Envelope
toString() - Method in class com.rabbitmq.client.GetResponse
toString() - Method in class com.rabbitmq.client.impl.AMQChannel
toString() - Method in class com.rabbitmq.client.impl.AMQCommand
toString() - Method in class com.rabbitmq.client.impl.AMQConnection
toString() - Method in class com.rabbitmq.client.impl.AMQContentHeader
toString() - Method in class com.rabbitmq.client.impl.Frame
toString() - Method in class com.rabbitmq.client.impl.Method
toString() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringConnection
toString() - Method in class com.rabbitmq.client.impl.VariableLinkedBlockingQueue
toString() - Method in class com.rabbitmq.client.impl.Version: Retrieve a String representation of the version in the standard AMQP version format of -
toString() - Method in interface com.rabbitmq.client.LongString: Get the content as a String.
toString() - Method in exception class com.rabbitmq.client.UnexpectedMethodError: Return a string representation of this error.
toString() - Method in exception class com.rabbitmq.client.UnknownClassOrMethodId
toString() - Method in class com.rabbitmq.utility.IntAllocator
toString(boolean) - Method in class com.rabbitmq.client.impl.AMQCommand
Tracer - Class in com.rabbitmq.tools: AMQP Protocol Analyzer program.
Tracer(int, String, String, int, Tracer.Logger, Properties) - Constructor for class com.rabbitmq.tools.Tracer
Tracer(String) - Constructor for class com.rabbitmq.tools.Tracer
Tracer(String, Properties) - Constructor for class com.rabbitmq.tools.Tracer
Tracer.AsyncLogger - Class in com.rabbitmq.tools: A Tracer.Logger designed to print Strings to a designated OutputStream on a private thread.
Tracer.Logger - Interface in com.rabbitmq.tools: Logging strings to an outputStream.
transformReply(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
transformReply(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel.SimpleBlockingRpcContinuation
transmit(AMQChannel) - Method in class com.rabbitmq.client.impl.AMQCommand: Sends this command down the named channel on the channel's connection, possibly in multiple frames.
transmit(AMQCommand) - Method in class com.rabbitmq.client.impl.AMQChannel
transmit(Method) - Method in class com.rabbitmq.client.impl.AMQChannel
TruncatedInputStream - Class in com.rabbitmq.client.impl: Utility stream: proxies another stream, making it appear to be no longer than a preset limit.
TruncatedInputStream(InputStream, long) - Constructor for class com.rabbitmq.client.impl.TruncatedInputStream
tryFill(Object, Map<String, Object>) - Static method in class com.rabbitmq.tools.json.JSONUtil: Ignores reflection exceptions while using reflection to fill public fields and Bean properties of the target object from the source Map.
Tune(int, int, int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
Tune(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
TuneOk(int, int, int) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
TuneOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
Tutorials - Search tag in interface com.rabbitmq.client.Channel: Section
Tx() - Constructor for class com.rabbitmq.client.AMQP.Tx
Tx() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Tx
txCommit() - Method in interface com.rabbitmq.client.Channel: Commits a TX transaction on this channel.
txCommit() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Commits a TX transaction on this channel.
txCommit() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
txRollback() - Method in interface com.rabbitmq.client.Channel: Rolls back a TX transaction on this channel.
txRollback() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Rolls back a TX transaction on this channel.
txRollback() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
txSelect() - Method in interface com.rabbitmq.client.Channel: Enables TX mode on this channel.
txSelect() - Method in class com.rabbitmq.client.impl.ChannelN: Public API - Enables TX mode on this channel.
txSelect() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
type - Variable in class com.rabbitmq.client.impl.Frame: Frame type code
type - Variable in class com.rabbitmq.tools.jsonrpc.ParameterDescription: The parameter type - one of "bit", "num", "str", "arr", "obj", "any" or "nil".
type(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
type(String) - Method in class com.rabbitmq.client.AMQP.Exchange.Declare.Builder
type(String) - Method in class com.rabbitmq.client.impl.recovery.RecordedExchange

U

Unbind(int, String, String, String, boolean, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
Unbind(int, String, String, String, Map<String, Object>) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
Unbind(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
Unbind(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
UnbindOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
UnbindOk() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
UnbindOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
UnbindOk(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
Unblocked() - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
Unblocked(MethodArgumentReader) - Constructor for class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
UNEXPECTED_FRAME - Static variable in interface com.rabbitmq.client.AMQP
UnexpectedFrameError - Exception Class in com.rabbitmq.client: Thrown when the command parser hits an unexpected frame type.
UnexpectedFrameError(Frame, int) - Constructor for exception class com.rabbitmq.client.UnexpectedFrameError
UnexpectedMethodError - Exception Class in com.rabbitmq.client: Indicates that a Method object was supplied that was not expected.
UnexpectedMethodError(Method) - Constructor for exception class com.rabbitmq.client.UnexpectedMethodError: Construct an UnexpecteMethodError with the given method parameter
uninterruptibleGet() - Method in class com.rabbitmq.utility.BlockingCell: As get(), but catches and ignores InterruptedException, retrying until a value appears.
uninterruptibleGet(int) - Method in class com.rabbitmq.utility.BlockingCell: As get(long timeout), but catches and ignores InterruptedException, retrying until a value appears or until specified timeout is reached.
uninterruptibleGetValue() - Method in class com.rabbitmq.utility.BlockingValueOrException
uninterruptibleGetValue(int) - Method in class com.rabbitmq.utility.BlockingValueOrException
UnknownClassOrMethodId - Exception Class in com.rabbitmq.client: Thrown when the protocol handlers detect an unknown class number or method number.
UnknownClassOrMethodId(int) - Constructor for exception class com.rabbitmq.client.UnknownClassOrMethodId
UnknownClassOrMethodId(int, int) - Constructor for exception class com.rabbitmq.client.UnknownClassOrMethodId
unlimit(K) - Method in class com.rabbitmq.client.impl.WorkPool
unregisterAllKeys() - Method in class com.rabbitmq.client.impl.WorkPool: Remove all clients from pool and from any other state.
unregisterKey(K) - Method in class com.rabbitmq.client.impl.WorkPool: Remove client from pool and from any other state.
USE_DEFAULT_PORT - Static variable in class com.rabbitmq.client.ConnectionFactory: 'Use the default port' port
User Guide - Search tag in interface com.rabbitmq.client.Channel: Section
userId(String) - Method in class com.rabbitmq.client.AMQP.BasicProperties.Builder
usesPrivateExecutor() - Method in class com.rabbitmq.client.impl.ConsumerWorkService
useSslProtocol() - Method in class com.rabbitmq.client.ConnectionFactory: Convenience method for setting up an SSL socket factory, using the JVM default SSL context and default trust store, with server hostname verification enabled.
useSslProtocol(String) - Method in class com.rabbitmq.client.ConnectionFactory: Convenience method for setting up an SSL socket factory, using the supplied protocol and the JVM default trust store, with server hostname verification enabled.
useSslProtocol(String, TrustManager) - Method in class com.rabbitmq.client.ConnectionFactory: Convenience method for setting up an SSL socket factory.
useSslProtocol(SSLContext) - Method in class com.rabbitmq.client.ConnectionFactory: Convenience method for setting up an SSL socket factory.
useTlsWithNoVerification() - Method in class com.rabbitmq.client.ConnectionFactory: Configure TLS without any certificate or hostname verification.
Utility - Class in com.rabbitmq.utility: Catch-all holder class for static helper methods.
Utility() - Constructor for class com.rabbitmq.utility.Utility

V

ValueOrException<V,E> - Class in com.rabbitmq.utility
ValueReader - Class in com.rabbitmq.client.impl: Helper class to read AMQP wire-protocol encoded values.
ValueReader(DataInputStream) - Constructor for class com.rabbitmq.client.impl.ValueReader: Construct a MethodArgumentReader streaming over the given DataInputStream.
ValueWriter - Class in com.rabbitmq.client.impl: Helper class to generate AMQP wire-protocol encoded values.
ValueWriter(DataOutputStream) - Constructor for class com.rabbitmq.client.impl.ValueWriter
VariableLinkedBlockingQueue<E> - Class in com.rabbitmq.client.impl: A clone of LinkedBlockingQueue with the addition of a VariableLinkedBlockingQueue.setCapacity(int) method, allowing us to change the capacity of the queue while it is in use.
VariableLinkedBlockingQueue() - Constructor for class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Creates a LinkedBlockingQueue with a capacity of Integer.MAX_VALUE.
VariableLinkedBlockingQueue(int) - Constructor for class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Creates a LinkedBlockingQueue with the given (fixed) capacity.
VariableLinkedBlockingQueue(Collection<? extends E>) - Constructor for class com.rabbitmq.client.impl.VariableLinkedBlockingQueue: Creates a LinkedBlockingQueue with a capacity of Integer.MAX_VALUE, initially containing the elements of the given collection, added in traversal order of the collection's iterator.
version - Variable in class com.rabbitmq.tools.jsonrpc.ServiceDescription: Version of the service
Version - Class in com.rabbitmq.client.impl: Encapsulation of AMQP protocol version
Version(int, int) - Constructor for class com.rabbitmq.client.impl.Version: Creates a new Version instance.
VERSION - Static variable in class com.rabbitmq.client.impl.ClientVersion: Full version string
versionMajor(int) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
versionMinor(int) - Method in class com.rabbitmq.client.AMQP.Connection.Start.Builder
virtualHost(String) - Method in class com.rabbitmq.client.AMQP.Connection.Open.Builder
visit(AMQImpl.Access.Request) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Access.Request) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Access.RequestOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Access.RequestOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Ack) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Ack) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Cancel) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Cancel) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.CancelOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.CancelOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Consume) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Consume) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.ConsumeOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.ConsumeOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Deliver) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Deliver) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Get) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Get) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.GetEmpty) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.GetEmpty) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.GetOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.GetOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Nack) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Nack) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Publish) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Publish) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Qos) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Qos) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.QosOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.QosOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Recover) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Recover) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.RecoverAsync) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.RecoverAsync) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.RecoverOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.RecoverOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Reject) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Reject) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Basic.Return) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Basic.Return) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Channel.Close) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Channel.Close) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Channel.CloseOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Channel.CloseOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Channel.Flow) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Channel.Flow) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Channel.FlowOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Channel.FlowOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Channel.Open) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Channel.Open) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Channel.OpenOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Channel.OpenOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Confirm.Select) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Confirm.Select) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Confirm.SelectOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Confirm.SelectOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Blocked) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Blocked) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Close) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Close) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.CloseOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.CloseOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Open) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Open) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.OpenOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.OpenOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Secure) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Secure) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.SecureOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.SecureOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Start) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Start) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.StartOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.StartOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Tune) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Tune) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.TuneOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.TuneOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Connection.Unblocked) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Connection.Unblocked) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.Bind) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.Bind) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.BindOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.BindOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.Declare) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.Declare) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.DeclareOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.DeclareOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.Delete) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.Delete) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.DeleteOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.DeleteOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.Unbind) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.Unbind) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Exchange.UnbindOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Exchange.UnbindOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
visit(AMQImpl.MethodVisitor) - Method in class com.rabbitmq.client.impl.Method: Visitor support (double-dispatch mechanism).
visit(AMQImpl.Queue.Bind) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.Bind) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.BindOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.BindOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.Declare) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.Declare) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.DeclareOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.DeclareOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.Delete) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.Delete) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.DeleteOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.DeleteOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.Purge) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.Purge) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.PurgeOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.PurgeOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.Unbind) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.Unbind) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Queue.UnbindOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Queue.UnbindOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Tx.Commit) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Tx.Commit) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Tx.CommitOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Tx.CommitOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Tx.Rollback) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Tx.Rollback) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Tx.RollbackOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Tx.RollbackOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Tx.Select) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Tx.Select) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor
visit(AMQImpl.Tx.SelectOk) - Method in class com.rabbitmq.client.impl.AMQImpl.DefaultMethodVisitor
visit(AMQImpl.Tx.SelectOk) - Method in interface com.rabbitmq.client.impl.AMQImpl.MethodVisitor

W

waitForConfirms() - Method in interface com.rabbitmq.client.Channel: Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
waitForConfirms() - Method in class com.rabbitmq.client.impl.ChannelN: Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
waitForConfirms() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
waitForConfirms(long) - Method in interface com.rabbitmq.client.Channel: Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.
waitForConfirms(long) - Method in class com.rabbitmq.client.impl.ChannelN: Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.
waitForConfirms(long) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
waitForConfirmsOrDie() - Method in interface com.rabbitmq.client.Channel: Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
waitForConfirmsOrDie() - Method in class com.rabbitmq.client.impl.ChannelN: Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
waitForConfirmsOrDie() - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
waitForConfirmsOrDie(long) - Method in interface com.rabbitmq.client.Channel: Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.
waitForConfirmsOrDie(long) - Method in class com.rabbitmq.client.impl.ChannelN: Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.
waitForConfirmsOrDie(long) - Method in class com.rabbitmq.client.impl.recovery.AutorecoveringChannel
willShutDownConsumerExecutor() - Method in class com.rabbitmq.client.impl.AMQConnection: Public API
WorkPool<K,W> - Class in com.rabbitmq.client.impl: This is a generic implementation of the Channels specification in Channeling Work, Nov 2010 (channels.pdf).
WorkPool() - Constructor for class com.rabbitmq.client.impl.WorkPool
wrap(ShutdownSignalException) - Static method in class com.rabbitmq.client.impl.AMQChannel: Placeholder until we address bug 15786 (implementing a proper exception hierarchy).
wrap(ShutdownSignalException, String) - Static method in class com.rabbitmq.client.impl.AMQChannel
write() - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
write(boolean) - Method in class com.rabbitmq.client.AMQP.Access.Request.Builder
write(boolean) - Method in class com.rabbitmq.tools.json.JSONWriter
write(char) - Method in class com.rabbitmq.tools.json.JSONWriter
write(double) - Method in class com.rabbitmq.tools.json.JSONWriter
write(long) - Method in class com.rabbitmq.tools.json.JSONWriter
write(Object) - Method in class com.rabbitmq.tools.json.JSONWriter
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.Request
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Access.RequestOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Ack
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Cancel
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.CancelOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Consume
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.ConsumeOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Deliver
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Get
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetEmpty
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.GetOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Nack
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Publish
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Qos
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.QosOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Recover
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverAsync
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.RecoverOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Reject
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Basic.Return
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Close
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.CloseOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Flow
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.FlowOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.Open
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Channel.OpenOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.Select
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Confirm.SelectOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Blocked
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Close
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.CloseOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Open
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.OpenOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Secure
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.SecureOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Start
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.StartOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Tune
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.TuneOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Connection.Unblocked
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Bind
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.BindOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Declare
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeclareOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Delete
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.DeleteOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.Unbind
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Exchange.UnbindOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Bind
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.BindOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Declare
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeclareOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Delete
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.DeleteOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Purge
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.PurgeOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.Unbind
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Queue.UnbindOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Commit
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.CommitOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Rollback
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.RollbackOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.Select
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.AMQImpl.Tx.SelectOk
writeArgumentsTo(MethodArgumentWriter) - Method in class com.rabbitmq.client.impl.Method: Private API - Autogenerated writer for this method.
writeArray(Object[]) - Method in class com.rabbitmq.client.impl.ValueWriter
writeArray(List<?>) - Method in class com.rabbitmq.client.impl.ValueWriter
writeBit(boolean) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a boolean/bit argument.
writeFieldValue(Object) - Method in class com.rabbitmq.client.impl.ValueWriter
writeFrame(Frame) - Method in class com.rabbitmq.client.impl.AMQConnection: Public API - sends a frame directly to the broker.
writeFrame(Frame) - Method in interface com.rabbitmq.client.impl.FrameHandler: Write a Frame to the underlying data connection.
writeFrame(Frame) - Method in class com.rabbitmq.client.impl.SocketFrameHandler
writeLimited(Class<?>, Object, String[]) - Method in class com.rabbitmq.tools.json.JSONWriter: Write only a certain subset of the object's properties and fields.
writeLong(int) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes an integer argument.
writeLong(int) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes an integer.
writeLong(Integer) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeLonglong(long) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a long integer argument.
writeLonglong(long) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a long integer.
writeLonglong(Long) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeLongstr(LongString) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeLongstr(LongString) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a long string argument from a LongString.
writeLongstr(LongString) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a long string from a LongString.
writeLongstr(String) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeLongstr(String) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a long string argument from a String.
writeLongstr(String) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a long string from a String.
writeOctet(byte) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes an octet argument from a byte.
writeOctet(byte) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes an octet from a byte.
writeOctet(int) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeOctet(int) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes an octet argument from an int.
writeOctet(int) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes an octet from an int.
writeOctet(Integer) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writePresence(boolean) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writePropertiesTo(ContentHeaderPropertyWriter) - Method in class com.rabbitmq.client.AMQP.BasicProperties
writePropertiesTo(ContentHeaderPropertyWriter) - Method in class com.rabbitmq.client.impl.AMQContentHeader: Private API - Autogenerated writer for this header
writeShort(int) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a short integer argument.
writeShort(int) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a short integer.
writeShort(Integer) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeShortstr(String) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeShortstr(String) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a short string argument.
writeShortstr(String) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a short string.
writeTable(Map<String, Object>) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeTable(Map<String, Object>) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a table argument.
writeTable(Map<String, Object>) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a table.
writeTimestamp(Date) - Method in class com.rabbitmq.client.impl.ContentHeaderPropertyWriter
writeTimestamp(Date) - Method in class com.rabbitmq.client.impl.MethodArgumentWriter: Public API - encodes a timestamp argument.
writeTimestamp(Date) - Method in class com.rabbitmq.client.impl.ValueWriter: Public API - encodes a timestamp.
writeTo(DataOutputStream) - Method in class com.rabbitmq.client.impl.Frame: Public API - writes this Frame to the given DataOutputStream

_

_blockContent - Variable in class com.rabbitmq.client.impl.AMQChannel: Whether transmission of content-bearing methods should be blocked
_blocker - Variable in class com.rabbitmq.client.impl.AMQChannel.BlockingRpcContinuation
_channelMutex - Variable in class com.rabbitmq.client.impl.AMQChannel: Protected; used instead of synchronizing on the channel itself, so that clients can themselves use the channel to synchronize on.
_workService - Variable in class com.rabbitmq.client.impl.AMQConnection

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