Index (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)

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

A

absoluteExpiryTime() - Method in interface com.rabbitmq.client.amqp.Message: Get the expiry time.
absoluteExpiryTime(long) - Method in interface com.rabbitmq.client.amqp.Message: Set the expiry time.
accept() - Method in interface com.rabbitmq.client.amqp.Consumer.Context: Accept the message (AMQP 1.0 accepted outcome).
ACCEPTED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition: see Consumer.Context.accept()
ACCEPTED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.PublishDisposition: see Publisher.Status.ACCEPTED
ACCEPTED - Enum constant in enum com.rabbitmq.client.amqp.Publisher.Status: The message has been accepted by the broker.
activated(boolean) - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder.RecoveryConfiguration: Whether to activate recovery or not.
Address - Class in com.rabbitmq.client.amqp: Utility class to represent a hostname and a port.
Address(String, int) - Constructor for class com.rabbitmq.client.amqp.Address
AddressBuilder<T> - Interface in com.rabbitmq.client.amqp: Builder for a AMQP target address format v2.
addressSelector(AddressSelector) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The AddressSelector to use.
AddressSelector - Interface in com.rabbitmq.client.amqp: Contract to pick an Address to connect to a cluster node.
affinity() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: Connection affinity settings.
AmqpConnectionException(String, Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpConnectionException
AmqpEntityDoesNotExistException(String) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpEntityDoesNotExistException
AmqpEntityDoesNotExistException(String, Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpEntityDoesNotExistException
AmqpEnvironmentBuilder - Class in com.rabbitmq.client.amqp.impl: Builder to create an Environment instance of the RabbitMQ AMQP 1.0 Java Client.
AmqpEnvironmentBuilder() - Constructor for class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder
AmqpEnvironmentBuilder.EnvironmentConnectionSettings - Interface in com.rabbitmq.client.amqp.impl: Common settings for connections created by an environment instance.
AmqpException - Exception Class in com.rabbitmq.client.amqp: Exception classes.
AmqpException(String, Object...) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException
AmqpException(String, Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException
AmqpException(Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException
AmqpException.AmqpConnectionException - Exception Class in com.rabbitmq.client.amqp: Exception related to connectivity problems.
AmqpException.AmqpEntityDoesNotExistException - Exception Class in com.rabbitmq.client.amqp: Exception thrown when an entity (exchange, queue) does not exit.
AmqpException.AmqpResourceClosedException - Exception Class in com.rabbitmq.client.amqp: Exception thrown when a resource is not usable because it is closed.
AmqpException.AmqpResourceInvalidStateException - Exception Class in com.rabbitmq.client.amqp: Exception thrown when a resource is not in an appropriate state.
AmqpException.AmqpSecurityException - Exception Class in com.rabbitmq.client.amqp: Exception related to security (authentication, permission, etc).
AmqpObservationDocumentation - Enum in com.rabbitmq.client.amqp.observation.micrometer: To generate documentation.
AmqpObservationDocumentation.HighCardinalityTags - Enum in com.rabbitmq.client.amqp.observation.micrometer: High cardinality tags.
AmqpObservationDocumentation.LowCardinalityTags - Enum in com.rabbitmq.client.amqp.observation.micrometer: Low cardinality tags.
AmqpResourceClosedException(String) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpResourceClosedException
AmqpResourceClosedException(String, Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpResourceClosedException
AmqpResourceInvalidStateException(String, Object...) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpResourceInvalidStateException
AmqpResourceInvalidStateException(String, Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpResourceInvalidStateException
AmqpSecurityException(String, Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpSecurityException
AmqpSecurityException(Throwable) - Constructor for exception class com.rabbitmq.client.amqp.AmqpException.AmqpSecurityException
annotation(String) - Method in interface com.rabbitmq.client.amqp.Message: Get the value of a message annotation.
annotation(String, Object) - Method in interface com.rabbitmq.client.amqp.Message: Set the value of a message annotation.
argument(String, Object) - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: Binding argument.
argument(String, Object) - Method in interface com.rabbitmq.client.amqp.Management.ExchangeSpecification: Exchange argument.
argument(String, Object) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Set a queue argument.
argument(String, Object) - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: A binding argument.
arguments() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The arguments of the queue.
arguments(Map<String, Object>) - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: Binding arguments.
arguments(Map<String, Object>) - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: Binding arguments.
AT_LEAST_ONCE - Enum constant in enum com.rabbitmq.client.amqp.Management.QuorumQueueDeadLetterStrategy: At-least-once strategy, guarantees for the message transfer between queues (with some caveats).
AT_MOST_ONCE - Enum constant in enum com.rabbitmq.client.amqp.Management.QuorumQueueDeadLetterStrategy: At-most-once strategy, dead-lettered messages can be lost in transit.
autoDelete() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: Whether the queue is deleted when last consumer unsubscribes.
autoDelete(boolean) - Method in interface com.rabbitmq.client.amqp.Management.ExchangeSpecification: Whether the exchange is deleted when last queue is unbound from it.
autoDelete(boolean) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Whether the queue get automatically deleted when its last consumer unsubscribes.

B

B(long) - Static method in class com.rabbitmq.client.amqp.ByteCapacity
backOffDelayPolicy(BackOffDelayPolicy) - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder.RecoveryConfiguration: Delay policy for connection attempts.
BackOffDelayPolicy - Interface in com.rabbitmq.client.amqp: Contract to determine a delay between attempts of some task.
BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy - Class in com.rabbitmq.client.amqp: Policy with an initial delay for the first attempt, then a fixed delay, and a timeout.
BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy - Class in com.rabbitmq.client.amqp: Policy with an initial delay for the first attempt, then a fixed delay.
BALANCED - Enum constant in enum com.rabbitmq.client.amqp.Management.QueueLeaderLocator: Takes into account the number of queues/leaders already running on each node in the cluster.
bind() - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: Create the binding.
binding() - Method in interface com.rabbitmq.client.amqp.Management: Start binding specification.
body() - Method in interface com.rabbitmq.client.amqp.Message: Get the message body.
body(byte[]) - Method in interface com.rabbitmq.client.amqp.Message: Set the body of the message.
build() - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder: Create the connection instance.
build() - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: Build the consumer.
build() - Method in interface com.rabbitmq.client.amqp.EnvironmentBuilder: Creates the Environment instance.
build() - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Create the environment instance.
build() - Method in class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder: Create the configured instance.
build() - Method in interface com.rabbitmq.client.amqp.PublisherBuilder: Build the configured instance.
build() - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: Build the configured instance.
build() - Method in interface com.rabbitmq.client.amqp.RpcServerBuilder: Create the configured instance.
builder() - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: Return the consumer builder.
ByteCapacity - Class in com.rabbitmq.client.amqp: API to easily configure byte capacities.

C

classic() - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Set the type to Management.QueueType.CLASSIC and return classic-queue-specific specification.
CLASSIC - Enum constant in enum com.rabbitmq.client.amqp.Management.QueueType: Classic queue.
CLIENT_LOCAL - Enum constant in enum com.rabbitmq.client.amqp.Management.QueueLeaderLocator: Pick the node the client is connected to.
close() - Method in interface com.rabbitmq.client.amqp.Connection: Close the connection and its resources
close() - Method in interface com.rabbitmq.client.amqp.Consumer: Close the consumer with its resources.
close() - Method in interface com.rabbitmq.client.amqp.Environment: Close the environment and its resources.
close() - Method in interface com.rabbitmq.client.amqp.Management: Close the management instance and release its resources.
close() - Method in interface com.rabbitmq.client.amqp.Publisher: Close the publisher and release its resources.
close() - Method in interface com.rabbitmq.client.amqp.RpcClient: Close the RPC client and its resources.
close() - Method in interface com.rabbitmq.client.amqp.RpcServer: Close the RPC server and its resources.
closeConnection() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Connection is closed.
closeConnection() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
closeConnection() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
closeConsumer() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Consumer is closed.
closeConsumer() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
closeConsumer() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
CLOSED - Enum constant in enum com.rabbitmq.client.amqp.Resource.State: The resource is closed.
closePublisher() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Publisher is closed.
closePublisher() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
closePublisher() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
CLOSING - Enum constant in enum com.rabbitmq.client.amqp.Resource.State: The resource is closing.
com.rabbitmq.client.amqp - package com.rabbitmq.client.amqp: Main API for the RabbitMQ AMQP 1.0 Java Client.
com.rabbitmq.client.amqp.impl - package com.rabbitmq.client.amqp.impl: Implementation package.
com.rabbitmq.client.amqp.metrics - package com.rabbitmq.client.amqp.metrics: Package for metrics collection utilities.
com.rabbitmq.client.amqp.observation.micrometer - package com.rabbitmq.client.amqp.observation.micrometer: Micrometer-based implementation for ObservationCollector.
compareTo(ByteCapacity) - Method in class com.rabbitmq.client.amqp.ByteCapacity
connection() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.Affinity: Return the connection builder.
connection() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.TlsSettings: The connection builder.
Connection - Interface in com.rabbitmq.client.amqp: A connection to the broker.
connectionBuilder() - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder.RecoveryConfiguration: The connection builder.
connectionBuilder() - Method in interface com.rabbitmq.client.amqp.Environment: Create a builder to configure and create a Connection.
ConnectionBuilder - Interface in com.rabbitmq.client.amqp: Builder for Connection instances.
ConnectionBuilder.RecoveryConfiguration - Interface in com.rabbitmq.client.amqp: Configuration for recovery.
connectionSettings() - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Returns connection settings shared by connection builders.
ConnectionSettings<T> - Interface in com.rabbitmq.client.amqp: Settings for a connection.
ConnectionSettings.Affinity<T> - Interface in com.rabbitmq.client.amqp: Connection affinity settings.
ConnectionSettings.Affinity.Operation - Enum in com.rabbitmq.client.amqp: Affinity operation.
ConnectionSettings.AffinityContext - Interface in com.rabbitmq.client.amqp: Context for the ConnectionSettings.AffinityStrategy.
ConnectionSettings.AffinityStrategy - Interface in com.rabbitmq.client.amqp: Strategy to pick candidate nodes with an affinity with a queue.
ConnectionSettings.TlsSettings<T> - Interface in com.rabbitmq.client.amqp: TLS settings.
consume() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Message is dispatched to a Consumer.
consume() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
consume() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
CONSUME - Enum constant in enum com.rabbitmq.client.amqp.ConnectionSettings.Affinity.Operation
consumeDisposition(MetricsCollector.ConsumeDisposition) - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Message is settled by a Consumer.
consumeDisposition(MetricsCollector.ConsumeDisposition) - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
consumeDisposition(MetricsCollector.ConsumeDisposition) - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
Consumer - Interface in com.rabbitmq.client.amqp: API to consume messages from a RabbitMQ queue.
Consumer.Context - Interface in com.rabbitmq.client.amqp: Context for message processing.
Consumer.MessageHandler - Interface in com.rabbitmq.client.amqp: Contract to process a message.
consumerBuilder() - Method in interface com.rabbitmq.client.amqp.Connection: Create a builder to configure and create a Consumer.
ConsumerBuilder - Interface in com.rabbitmq.client.amqp: API to configure and create a Consumer.
ConsumerBuilder.StreamOffsetSpecification - Enum in com.rabbitmq.client.amqp: Offset specification to start consuming from.
ConsumerBuilder.StreamOptions - Interface in com.rabbitmq.client.amqp: Options for a consumer consuming from a stream.
consumerCount() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The number of consumers the queue has.
consumerExecutorService(ExecutorService) - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Set executor service used for consumer loops.
contentEncoding() - Method in interface com.rabbitmq.client.amqp.Message: Get the content-encoding.
contentEncoding(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the content-encoding.
contentType() - Method in interface com.rabbitmq.client.amqp.Message: Get the content-type.
contentType(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the content-type.
correlationId() - Method in interface com.rabbitmq.client.amqp.Message: Get message correlation ID.
correlationId() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DeliverContext
correlationId() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
correlationId(byte[]) - Method in interface com.rabbitmq.client.amqp.Message: Set the message correlation ID (array of bytes).
correlationId(long) - Method in interface com.rabbitmq.client.amqp.Message: Set the message correlation ID (long).
correlationId(Object) - Method in interface com.rabbitmq.client.amqp.Message: Set the message correlation ID.
correlationId(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the message correlation ID (string).
correlationId(UUID) - Method in interface com.rabbitmq.client.amqp.Message: Set the message correlation ID (UUID).
correlationIdAsBinary() - Method in interface com.rabbitmq.client.amqp.Message: Get message correlation ID as an array of bytes.
correlationIdAsLong() - Method in interface com.rabbitmq.client.amqp.Message: Get message correlation ID as a long.
correlationIdAsString() - Method in interface com.rabbitmq.client.amqp.Message: Get message correlation ID as a string.
correlationIdAsUuid() - Method in interface com.rabbitmq.client.amqp.Message: Get message correlation ID as a UUID.
correlationIdExtractor(Function<Message, Object>) - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: Callback to extract the correlation ID from a reply message.
correlationIdExtractor(Function<Message, Object>) - Method in interface com.rabbitmq.client.amqp.RpcServerBuilder: Logic to extract the correlation ID from a request message.
correlationIdSupplier(Supplier<Object>) - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: The generator for correlation ID.
creationTime() - Method in interface com.rabbitmq.client.amqp.Message: Get the creation time.
creationTime(long) - Method in interface com.rabbitmq.client.amqp.Message: Set the creation time.
credentialsProvider(CredentialsProvider) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The CredentialsProvider to use.
CredentialsProvider - Interface in com.rabbitmq.client.amqp: Marker interface for providing credentials.
currentState() - Method in interface com.rabbitmq.client.amqp.Resource.Context: The current (new) state of the resource.
customProcessConvention(DeliverObservationConvention) - Method in class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder: Set the custom ObservationConvention for processing (consuming).
customPublishConvention(PublishObservationConvention) - Method in class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder: Set the custom ObservationConvention for publishing.

D

deadLetterExchange(String) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: The dead letter exchange.
deadLetterRoutingKey(String) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: The dead letter routing key.
deadLetterStrategy(Management.QuorumQueueDeadLetterStrategy) - Method in interface com.rabbitmq.client.amqp.Management.QuorumQueueSpecification: The dead letter strategy.
deadLetterStrategy(String) - Method in interface com.rabbitmq.client.amqp.Management.QuorumQueueSpecification: The dead letter strategy (as a string).
declare() - Method in interface com.rabbitmq.client.amqp.Management.ExchangeSpecification: Declare the exchange.
declare() - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Declare the queue.
defaultProcessConvention(DeliverObservationConvention) - Method in class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder: Set the default ObservationConvention for processing (consuming).
DefaultProcessObservationConvention - Class in com.rabbitmq.client.amqp.observation.micrometer: Default ObservationConvention for processing (consuming).
DefaultProcessObservationConvention() - Constructor for class com.rabbitmq.client.amqp.observation.micrometer.DefaultProcessObservationConvention
defaultPublishConvention(PublishObservationConvention) - Method in class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder: Set the default ObservationConvention for publishing.
DefaultPublishObservationConvention - Class in com.rabbitmq.client.amqp.observation.micrometer: Default ObservationConvention for publishing.
DefaultPublishObservationConvention() - Constructor for class com.rabbitmq.client.amqp.observation.micrometer.DefaultPublishObservationConvention
DefaultUsernamePasswordCredentialsProvider - Class in com.rabbitmq.client.amqp: Default implementation of UsernamePasswordCredentialsProvider.
DefaultUsernamePasswordCredentialsProvider(String, String) - Constructor for class com.rabbitmq.client.amqp.DefaultUsernamePasswordCredentialsProvider
delay(int) - Method in interface com.rabbitmq.client.amqp.BackOffDelayPolicy: Returns the delay to use for a given attempt.
delay(int) - Method in class com.rabbitmq.client.amqp.BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy
delay(int) - Method in class com.rabbitmq.client.amqp.BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy
delete(String) - Method in interface com.rabbitmq.client.amqp.Management.ExchangeDeletion: Delete the exchange.
delete(String) - Method in interface com.rabbitmq.client.amqp.Management.QueueDeletion: Delete the queue.
DeliverContext - Class in com.rabbitmq.client.amqp.observation.micrometer: Delivery context.
DeliverObservationConvention - Interface in com.rabbitmq.client.amqp.observation.micrometer: Contract for delivery (processing/consuming) ObservationConvention.
deliveryLimit(int) - Method in interface com.rabbitmq.client.amqp.Management.QuorumQueueSpecification: Set the delivery limit (for poison message handling).
destinationExchange(String) - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: The destination exchange.
destinationExchange(String) - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: The destination exchange.
destinationQueue(String) - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: The destination queue.
destinationQueue(String) - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: The destination queue.
DIRECT - Enum constant in enum com.rabbitmq.client.amqp.Management.ExchangeType: Direct exchange type.
discard() - Method in interface com.rabbitmq.client.amqp.Consumer.Context: Discard the message (AMQP 1.0 rejected outcome).
DISCARDED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition: see Consumer.Context.discard()
DROP_HEAD - Enum constant in enum com.rabbitmq.client.amqp.Management.OverFlowStrategy: Drop the messages at the head of the queue.
durable() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: Whether the queue is durable (will survive a server restart).
durable() - Method in interface com.rabbitmq.client.amqp.Message: Whether the message is durable.

E

Environment - Interface in com.rabbitmq.client.amqp: The Environment is the main entry point to a node or a cluster of nodes.
environmentBuilder() - Method in interface com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder.EnvironmentConnectionSettings: The owning environment builder.
EnvironmentBuilder - Interface in com.rabbitmq.client.amqp: Builder for Environment instances.
equals(Object) - Method in class com.rabbitmq.client.amqp.Address
equals(Object) - Method in class com.rabbitmq.client.amqp.ByteCapacity
exchange() - Method in interface com.rabbitmq.client.amqp.Management: Start exchange specification.
exchange() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DeliverContext
exchange() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
exchange(String) - Method in interface com.rabbitmq.client.amqp.AddressBuilder: Set the exchange.
exchange(String) - Method in interface com.rabbitmq.client.amqp.Management: Start exchange specification.
exchangeDeletion() - Method in interface com.rabbitmq.client.amqp.Management: Delete an exchange.
exclusive() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: Whether the queue is used by only one connection and will be deleted when that connection closes.
exclusive(boolean) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Whether the queue is exclusive or not.
executorService(ExecutorService) - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Set executor service used for internal tasks (e.g. connection recovery).
expires(Duration) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Set TTL for a queue.

F

failureCause() - Method in interface com.rabbitmq.client.amqp.Resource.Context: The failure cause, can be null.
FANOUT - Enum constant in enum com.rabbitmq.client.amqp.Management.ExchangeType: Fanout exchange type.
filterMatchUnfiltered(boolean) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: Whether messages without a filter value should be sent.
filterValues(String...) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: Filter values.
FIRST - Enum constant in enum com.rabbitmq.client.amqp.ConsumerBuilder.StreamOffsetSpecification: Beginning of the stream.
firstAcquirer() - Method in interface com.rabbitmq.client.amqp.Message: Whether the message may have been acquired by another link.
fixed(Duration) - Static method in interface com.rabbitmq.client.amqp.BackOffDelayPolicy: Policy with a fixed delay.
fixedWithInitialDelay(Duration, Duration) - Static method in interface com.rabbitmq.client.amqp.BackOffDelayPolicy: Policy with an initial delay for the first attempt, then a fixed delay.
fixedWithInitialDelay(Duration, Duration, Duration) - Static method in interface com.rabbitmq.client.amqp.BackOffDelayPolicy: Policy with an initial delay for the first attempt, then a fixed delay, and a timeout.
forEachAnnotation(BiConsumer<String, Object>) - Method in interface com.rabbitmq.client.amqp.Message: Iterate over message annotations.
forEachProperty(BiConsumer<String, Object>) - Method in interface com.rabbitmq.client.amqp.Message: Iterate over application properties.
from(String) - Static method in class com.rabbitmq.client.amqp.ByteCapacity

G

GB(long) - Static method in class com.rabbitmq.client.amqp.ByteCapacity
getContextualName(DeliverContext) - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultProcessObservationConvention
getContextualName(PublishContext) - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultPublishObservationConvention
getHighCardinalityKeyValues(DeliverContext) - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultProcessObservationConvention
getHighCardinalityKeyValues(PublishContext) - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultPublishObservationConvention
getLowCardinalityKeyValues(DeliverContext) - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultProcessObservationConvention
getLowCardinalityKeyValues(PublishContext) - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultPublishObservationConvention
getName() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultProcessObservationConvention
getName() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DefaultPublishObservationConvention
getPassword() - Method in class com.rabbitmq.client.amqp.DefaultUsernamePasswordCredentialsProvider
getPassword() - Method in interface com.rabbitmq.client.amqp.UsernamePasswordCredentialsProvider: The password
getUsername() - Method in class com.rabbitmq.client.amqp.DefaultUsernamePasswordCredentialsProvider
getUsername() - Method in interface com.rabbitmq.client.amqp.UsernamePasswordCredentialsProvider: The username
groupId() - Method in interface com.rabbitmq.client.amqp.Message: Get the group ID.
groupId(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the group ID.
groupSequence() - Method in interface com.rabbitmq.client.amqp.Message: Get the message position in its group.
groupSequence(int) - Method in interface com.rabbitmq.client.amqp.Message: Set the position of the message in its group.

H

handle(Consumer.Context, Message) - Method in interface com.rabbitmq.client.amqp.Consumer.MessageHandler: Process a message
handle(Publisher.Context) - Method in interface com.rabbitmq.client.amqp.Publisher.Callback: Handle broker feedback.
handle(Resource.Context) - Method in interface com.rabbitmq.client.amqp.Resource.StateListener: Handle state change.
handle(RpcServer.Context, Message) - Method in interface com.rabbitmq.client.amqp.RpcServer.Handler: Process request message.
handler(RpcServer.Handler) - Method in interface com.rabbitmq.client.amqp.RpcServerBuilder: The logic to process requests and issue replies.
hasAnnotation(String) - Method in interface com.rabbitmq.client.amqp.Message: Whether a message annotation is set.
hasAnnotations() - Method in interface com.rabbitmq.client.amqp.Message: Whether the message has message annotation.
hashCode() - Method in class com.rabbitmq.client.amqp.Address
hashCode() - Method in class com.rabbitmq.client.amqp.ByteCapacity
hasProperties() - Method in interface com.rabbitmq.client.amqp.Message: Whether at least one application property is set on the message.
hasProperty(String) - Method in interface com.rabbitmq.client.amqp.Message: Check an application property is set.
HEADERS - Enum constant in enum com.rabbitmq.client.amqp.Management.ExchangeType: Headers Exchange Type.
host() - Method in class com.rabbitmq.client.amqp.Address
host(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The host to connect to.
hostnameVerification() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.TlsSettings: Activate hostname verification.
hostnameVerification(boolean) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.TlsSettings: Whether to activate hostname verification or not.

I

idleTimeout(Duration) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: Idle timeout (heartbeat) to use.
initialClusterSize(int) - Method in interface com.rabbitmq.client.amqp.Management.StreamSpecification: Set the number of nodes the initial stream cluster should span.
initialCredits(int) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: The initial number credits to grant to the AMQP receiver.
INSTANCE - Static variable in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector

K

kB(long) - Static method in class com.rabbitmq.client.amqp.ByteCapacity
key(String) - Method in interface com.rabbitmq.client.amqp.AddressBuilder: Set the routing key.
key(String) - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: The binding key.
key(String) - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: The binding key.

L

LAST - Enum constant in enum com.rabbitmq.client.amqp.ConsumerBuilder.StreamOffsetSpecification: Last chunk of the stream.
leader() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The node the leader of the queue is on.
leaderLocator(Management.QueueLeaderLocator) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Leader-locator strategy (replica placement) for the queue.
listeners(Resource.StateListener...) - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder: Add Resource.StateListeners to the connection.
listeners(Resource.StateListener...) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: Add Resource.StateListeners to the consumer.
listeners(Resource.StateListener...) - Method in interface com.rabbitmq.client.amqp.PublisherBuilder: Add Resource.StateListeners to the consumer.
locator() - Method in enum com.rabbitmq.client.amqp.Management.QueueLeaderLocator

M

management() - Method in interface com.rabbitmq.client.amqp.Connection: The Management instance of this connection.
Management - Interface in com.rabbitmq.client.amqp: API to manage AMQ 0.9.1 model topology (exchanges, queues, and bindings).
Management.BindingSpecification - Interface in com.rabbitmq.client.amqp: Specification of a binding.
Management.ClassicQueueSpecification - Interface in com.rabbitmq.client.amqp: Specification of a classic queue.
Management.ClassicQueueVersion - Enum in com.rabbitmq.client.amqp: Classic queue version.
Management.ExchangeDeletion - Interface in com.rabbitmq.client.amqp: Exchange deletion.
Management.ExchangeSpecification - Interface in com.rabbitmq.client.amqp: Specification of an exchange.
Management.ExchangeType - Enum in com.rabbitmq.client.amqp: Exchange type.
Management.OverFlowStrategy - Enum in com.rabbitmq.client.amqp: Overflow strategy (when a queue reaches its maximum length limit).
Management.QueueDeletion - Interface in com.rabbitmq.client.amqp: Queue deletion.
Management.QueueInfo - Interface in com.rabbitmq.client.amqp: Queue information.
Management.QueueLeaderLocator - Enum in com.rabbitmq.client.amqp: Queue leader locator.
Management.QueueSpecification - Interface in com.rabbitmq.client.amqp: Specification to create a queue.
Management.QueueType - Enum in com.rabbitmq.client.amqp: Queue Type.
Management.QuorumQueueDeadLetterStrategy - Enum in com.rabbitmq.client.amqp: Dead letter strategy for quorum queues.
Management.QuorumQueueSpecification - Interface in com.rabbitmq.client.amqp: Specification of a quorum queue.
Management.StreamSpecification - Interface in com.rabbitmq.client.amqp: Specification of a stream.
Management.UnbindSpecification - Interface in com.rabbitmq.client.amqp: Unbind specification.
maxAge(Duration) - Method in interface com.rabbitmq.client.amqp.Management.StreamSpecification: Set the maximum age of a stream before it gets truncated.
maxLength(long) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Maximum length for a queue.
maxLengthBytes(ByteCapacity) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Maximum length in bytes for a queue.
maxPriority(int) - Method in interface com.rabbitmq.client.amqp.Management.ClassicQueueSpecification: Declare a priority queue and set the maximum priority.
maxSegmentSizeBytes(ByteCapacity) - Method in interface com.rabbitmq.client.amqp.Management.StreamSpecification: Set the maximum size for the stream segment files.
MB(long) - Static method in class com.rabbitmq.client.amqp.ByteCapacity
message() - Method in interface com.rabbitmq.client.amqp.Message.MessageAddressBuilder
message() - Method in interface com.rabbitmq.client.amqp.Publisher.Context: The message.
message() - Method in interface com.rabbitmq.client.amqp.Publisher: Create a message meant to be published by the publisher instance.
message() - Method in interface com.rabbitmq.client.amqp.RpcClient: Create a message meant to be published by the underlying publisher instance.
message() - Method in interface com.rabbitmq.client.amqp.RpcServer.Context: Create a message meant to be published by the underlying publisher instance.
message(byte[]) - Method in interface com.rabbitmq.client.amqp.Publisher: Create a message meant to be published by the publisher instance.
message(byte[]) - Method in interface com.rabbitmq.client.amqp.RpcClient: Create a message meant to be published by the underlying publisher instance.
message(byte[]) - Method in interface com.rabbitmq.client.amqp.RpcServer.Context: Create a message meant to be published by the underlying publisher instance.
Message - Interface in com.rabbitmq.client.amqp: AMQP 1.0 message.
Message.MessageAddressBuilder - Interface in com.rabbitmq.client.amqp: Message AddressBuilder.
messageCount() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The number of messages in the queue.
messageHandler(Consumer.MessageHandler) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: The callback for inbound messages.
messageId() - Method in interface com.rabbitmq.client.amqp.Message: Get message ID.
messageId() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DeliverContext
messageId() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
messageId(byte[]) - Method in interface com.rabbitmq.client.amqp.Message: Set the message ID (array of bytes).
messageId(long) - Method in interface com.rabbitmq.client.amqp.Message: Set the message ID (long).
messageId(Object) - Method in interface com.rabbitmq.client.amqp.Message: Set the message ID.
messageId(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the message ID (string).
messageId(UUID) - Method in interface com.rabbitmq.client.amqp.Message: Set the message ID (UUID).
messageIdAsBinary() - Method in interface com.rabbitmq.client.amqp.Message: Get message ID as an array of bytes.
messageIdAsLong() - Method in interface com.rabbitmq.client.amqp.Message: Get message ID as a long.
messageIdAsString() - Method in interface com.rabbitmq.client.amqp.Message: Get message ID as a string.
messageIdAsUuid() - Method in interface com.rabbitmq.client.amqp.Message: Get message ID as a UUID.
messageTtl(Duration) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Set the message TTL for the queue.
MESSAGING_DESTINATION_NAME - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
MESSAGING_MESSAGE_CONVERSATION_ID - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
MESSAGING_MESSAGE_ID - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
MESSAGING_MESSAGE_PAYLOAD_SIZE_BYTES - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
MESSAGING_OPERATION - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.LowCardinalityTags: A string identifying the kind of messaging operation.
MESSAGING_ROUTING_KEY - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
MESSAGING_SOURCE_NAME - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
MESSAGING_SYSTEM - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.LowCardinalityTags: A string identifying the messaging system.
metricsCollector(MetricsCollector) - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Set up a MetricsCollector.
MetricsCollector - Interface in com.rabbitmq.client.amqp.metrics: Interface to collect execution data of the client.
MetricsCollector.ConsumeDisposition - Enum in com.rabbitmq.client.amqp.metrics: The client-to-broker dispositions.
MetricsCollector.PublishDisposition - Enum in com.rabbitmq.client.amqp.metrics: The broker-to-client dispositions.
MicrometerMetricsCollector - Class in com.rabbitmq.client.amqp.metrics: MetricsCollector implementation using Micrometer.
MicrometerMetricsCollector(MeterRegistry) - Constructor for class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
MicrometerMetricsCollector(MeterRegistry, String) - Constructor for class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
MicrometerMetricsCollector(MeterRegistry, String, Iterable<Tag>) - Constructor for class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
MicrometerMetricsCollector(MeterRegistry, String, String...) - Constructor for class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
MicrometerObservationCollectorBuilder - Class in com.rabbitmq.client.amqp.observation.micrometer: Builder to create an instance of ObservationCollector using Micrometer observation.
MicrometerObservationCollectorBuilder() - Constructor for class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder

N

name() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The name of the queue.
name(String) - Method in interface com.rabbitmq.client.amqp.Management.ExchangeSpecification: The name of the exchange.
name(String) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: The name of the queue.
NET_PROTOCOL_NAME - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.LowCardinalityTags: A string identifying the protocol (AMQP).
NET_PROTOCOL_VERSION - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.LowCardinalityTags: A string identifying the protocol version (1.0).
NET_SOCK_PEER_ADDR - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
NET_SOCK_PEER_PORT - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags
NEXT - Enum constant in enum com.rabbitmq.client.amqp.ConsumerBuilder.StreamOffsetSpecification: Very end of the stream (new chunks).
nodesWithAffinity(ConnectionSettings.AffinityContext, Management.QueueInfo) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.AffinityStrategy: Pick affinity.
NoOpMetricsCollector - Class in com.rabbitmq.client.amqp.metrics: No-operation implementation of MetricsCollector.

O

observationCollector(ObservationCollector) - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Set up an ObservationCollector.
ObservationCollector - Interface in com.rabbitmq.client.amqp: API to observe common message operations.
ObservationCollector.ConnectionInfo - Interface in com.rabbitmq.client.amqp: Information on a connection.
offset(long) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: The offset to start consuming from.
offset(ConsumerBuilder.StreamOffsetSpecification) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: The offset to start consuming from.
offset(String) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: The offset to start consuming from as an interval string value.
offset(Instant) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions: A point in time to start consuming from.
OPEN - Enum constant in enum com.rabbitmq.client.amqp.Resource.State: The resource is open and functional.
openConnection() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a new Connection is opened.
openConnection() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
openConnection() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
openConsumer() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a new Consumer is opened.
openConsumer() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
openConsumer() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
OPENING - Enum constant in enum com.rabbitmq.client.amqp.Resource.State: The resource is currently opening.
openPublisher() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a new Publisher is opened.
openPublisher() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
openPublisher() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
operation() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.AffinityContext: Operation for affinity.
operation(ConnectionSettings.Affinity.Operation) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.Affinity: The type of operation to look affinity with.
overflowStrategy(Management.OverFlowStrategy) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: The overflow strategy.
overflowStrategy(String) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: The overflow strategy (as a string).

P

password(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The password to use.
pause() - Method in interface com.rabbitmq.client.amqp.Consumer: Pause the consumer to stop receiving messages.
payloadSizeBytes() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DeliverContext
payloadSizeBytes() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
peerAddress() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
peerAddress() - Method in interface com.rabbitmq.client.amqp.ObservationCollector.ConnectionInfo: Remote (broker) address.
peerPort() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
peerPort() - Method in interface com.rabbitmq.client.amqp.ObservationCollector.ConnectionInfo: Remote (broker) port.
port() - Method in class com.rabbitmq.client.amqp.Address
port(int) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The port to use to connect.
previousState() - Method in interface com.rabbitmq.client.amqp.Resource.Context: The previous state of the resource.
priority() - Method in interface com.rabbitmq.client.amqp.Message: Get the message priority.
priority(byte) - Method in interface com.rabbitmq.client.amqp.Message: Set the priority of the message.
priority(int) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: The consumer priority.
PROCESS_OBSERVATION - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation: Observation for processing a message.
property(String) - Method in interface com.rabbitmq.client.amqp.Message: Get the value of an application property.
property(String, boolean) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, byte) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, byte[]) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, char) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, double) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, float) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, int) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, long) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, short) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, String) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
property(String, UUID) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyDecimal128(String, BigDecimal) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyDecimal32(String, BigDecimal) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyDecimal64(String, BigDecimal) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertySymbol(String, String) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyTimestamp(String, long) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyUnsigned(String, byte) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyUnsigned(String, int) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyUnsigned(String, long) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
propertyUnsigned(String, short) - Method in interface com.rabbitmq.client.amqp.Message: Set an application property.
publish() - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Message is published.
publish() - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
publish() - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
publish(Message) - Method in interface com.rabbitmq.client.amqp.RpcClient: Publish a request message and expect a response.
publish(Message, Publisher.Callback) - Method in interface com.rabbitmq.client.amqp.Publisher: Publish a message.
publish(String, String, Message, ObservationCollector.ConnectionInfo, Function<Message, T>) - Method in interface com.rabbitmq.client.amqp.ObservationCollector: Observe the publishing of a message.
PUBLISH - Enum constant in enum com.rabbitmq.client.amqp.ConnectionSettings.Affinity.Operation
PUBLISH_OBSERVATION - Enum constant in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation: Observation for publishing a message.
PublishContext - Class in com.rabbitmq.client.amqp.observation.micrometer: Publish context.
publishDisposition(MetricsCollector.PublishDisposition) - Method in interface com.rabbitmq.client.amqp.metrics.MetricsCollector: Called when a Message is settled by the broker.
publishDisposition(MetricsCollector.PublishDisposition) - Method in class com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector
publishDisposition(MetricsCollector.PublishDisposition) - Method in class com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector
Publisher - Interface in com.rabbitmq.client.amqp: API to send messages.
Publisher.Callback - Interface in com.rabbitmq.client.amqp: API to deal with the feedback the broker provides after its processing of a published message.
Publisher.Context - Interface in com.rabbitmq.client.amqp: Feedback context.
Publisher.Status - Enum in com.rabbitmq.client.amqp: Message status.
publisherBuilder() - Method in interface com.rabbitmq.client.amqp.Connection: Create a builder to configure and create a Publisher.
PublisherBuilder - Interface in com.rabbitmq.client.amqp: API to configure and create a Publisher.
publisherExecutorService(ExecutorService) - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Set executor service used to deal with broker responses after processing outbound messages.
PublishObservationConvention - Interface in com.rabbitmq.client.amqp.observation.micrometer: Contract for publishing ObservationConvention.
publishTimeout(Duration) - Method in interface com.rabbitmq.client.amqp.PublisherBuilder: The timeout to wait for a response from the broker.

Q

queue() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.AffinityContext: Queue to have affinity with.
queue() - Method in interface com.rabbitmq.client.amqp.Management.ClassicQueueSpecification: Go back to the queue specification.
queue() - Method in interface com.rabbitmq.client.amqp.Management: Start queue specification.
queue() - Method in interface com.rabbitmq.client.amqp.Management.QuorumQueueSpecification: Go back to the queue specification.
queue() - Method in interface com.rabbitmq.client.amqp.Management.StreamSpecification: Go back to the queue specification.
queue() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DeliverContext
queue(String) - Method in interface com.rabbitmq.client.amqp.AddressBuilder: Set the queue.
queue(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.Affinity: The queue to have affinity with.
queue(String) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: The queue to consume from.
queue(String) - Method in interface com.rabbitmq.client.amqp.Management: Start queue specification.
queueDeletion() - Method in interface com.rabbitmq.client.amqp.Management: Delete a queue.
queueInfo(String) - Method in interface com.rabbitmq.client.amqp.Management: Query information on a queue.
quorum() - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Set the type to Management.QueueType.QUORUM and return quorum-queue-specific specification.
QUORUM - Enum constant in enum com.rabbitmq.client.amqp.Management.QueueType: Quorum queue.
quorumInitialGroupSize(int) - Method in interface com.rabbitmq.client.amqp.Management.QuorumQueueSpecification: Set the number of quorum queue members.

R

RECOVERING - Enum constant in enum com.rabbitmq.client.amqp.Resource.State: The resource is recovering.
recovery() - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder: Configuration for recovery.
registry(ObservationRegistry) - Method in class com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder: Set the Micrometer's ObservationRegistry.
REJECT_PUBLISH - Enum constant in enum com.rabbitmq.client.amqp.Management.OverFlowStrategy: Discard the most recent published messages.
REJECT_PUBLISH_DLX - Enum constant in enum com.rabbitmq.client.amqp.Management.OverFlowStrategy: Discard the most recent published messages and dead-letter them.
REJECTED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.PublishDisposition: see Publisher.Status.REJECTED
REJECTED - Enum constant in enum com.rabbitmq.client.amqp.Publisher.Status: At least one queue the message was routed to rejected the message.
RELEASED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.PublishDisposition: see Publisher.Status.RELEASED
RELEASED - Enum constant in enum com.rabbitmq.client.amqp.Publisher.Status: The broker could not route the message to any queue.
removeAnnotation(String) - Method in interface com.rabbitmq.client.amqp.Message: Remove an annotation.
removeProperty(String) - Method in interface com.rabbitmq.client.amqp.Message: Remove an application property.
replicas() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The nodes the queue has replicas (members) on.
replyPostProcessor(BiFunction<Message, Object, Message>) - Method in interface com.rabbitmq.client.amqp.RpcServerBuilder: A callback called after request processing but before sending the reply message.
replyTo() - Method in interface com.rabbitmq.client.amqp.Message: Get the reply-to field.
replyTo(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the reply-to field.
replyToAddress() - Method in interface com.rabbitmq.client.amqp.Message: AddressBuilder for the Message.replyTo() field.
replyToGroupId() - Method in interface com.rabbitmq.client.amqp.Message: Get the reply-to group ID.
replyToGroupId(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the reply-to group ID.
replyToQueue(String) - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: The queue the client expects responses on.
requestAddress() - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: Builder for the request address.
requestPostProcessor(BiFunction<Message, Object, Message>) - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: A callback before sending a request message.
requestQueue(String) - Method in interface com.rabbitmq.client.amqp.RpcServerBuilder: The queue to wait for requests on.
requestTimeout(Duration) - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder: Timeout before failing outstanding requests.
requeue() - Method in interface com.rabbitmq.client.amqp.Consumer.Context: Requeue the message (AMQP 1.0 released outcome).
REQUEUED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition: see Consumer.Context.requeue()
resource() - Method in interface com.rabbitmq.client.amqp.Resource.Context: The resource instance.
Resource - Interface in com.rabbitmq.client.amqp: Marker interface for Resource-like classes.
Resource.Context - Interface in com.rabbitmq.client.amqp: Context of a resource state change.
Resource.State - Enum in com.rabbitmq.client.amqp: Resource state.
Resource.StateListener - Interface in com.rabbitmq.client.amqp: Application listener for a Resource.
reuse(boolean) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.Affinity: Whether an open connection with the same affinity should reused.
routingKey() - Method in class com.rabbitmq.client.amqp.observation.micrometer.DeliverContext
routingKey() - Method in class com.rabbitmq.client.amqp.observation.micrometer.PublishContext
rpcClient() - Method in interface com.rabbitmq.client.amqp.RpcClientBuilder.RpcClientAddressBuilder: Go back to the RPC client builder.
RpcClient - Interface in com.rabbitmq.client.amqp: Client support class for RPC.
rpcClientBuilder() - Method in interface com.rabbitmq.client.amqp.Connection: Create a builder to configure and create a RpcClientBuilder.
RpcClientBuilder - Interface in com.rabbitmq.client.amqp: API to configure and create a RpcClient.
RpcClientBuilder.RpcClientAddressBuilder - Interface in com.rabbitmq.client.amqp: Builder for the request address.
RpcServer - Interface in com.rabbitmq.client.amqp: Client server class for RPC.
RpcServer.Context - Interface in com.rabbitmq.client.amqp: Request processing context.
RpcServer.Handler - Interface in com.rabbitmq.client.amqp: Contract to process a request message and return a reply message.
rpcServerBuilder() - Method in interface com.rabbitmq.client.amqp.Connection: Create a builder to configure and create a RpcServerBuilder.
RpcServerBuilder - Interface in com.rabbitmq.client.amqp: API to configure and create a RpcServer.

S

SASL_MECHANISM_ANONYMOUS - Static variable in interface com.rabbitmq.client.amqp.ConnectionSettings: ANONYMOUS SASL mechanism (the default).
SASL_MECHANISM_EXTERNAL - Static variable in interface com.rabbitmq.client.amqp.ConnectionSettings: EXTERNAL SASL mechanism (e.g. client certificate).
SASL_MECHANISM_PLAIN - Static variable in interface com.rabbitmq.client.amqp.ConnectionSettings: PLAIN SASL mechanism (username and password).
saslMechanism(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: SASL mechanism to use.
scheduledExecutorService(ScheduledExecutorService) - Method in class com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder: Set scheduled executor service used for internal tasks (e.g. connection recovery).
select(List<Address>) - Method in interface com.rabbitmq.client.amqp.AddressSelector: Pick an address from a list.
singleActiveConsumer(boolean) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Activate "single active consumer" on the queue.
sourceExchange(String) - Method in interface com.rabbitmq.client.amqp.Management.BindingSpecification: The source exchange.
sourceExchange(String) - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: The source exchange.
sslContext(SSLContext) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.TlsSettings: SSLContext to use.
status() - Method in interface com.rabbitmq.client.amqp.Publisher.Context: The status returned by the broker.
strategy() - Method in enum com.rabbitmq.client.amqp.Management.OverFlowStrategy
strategy() - Method in enum com.rabbitmq.client.amqp.Management.QuorumQueueDeadLetterStrategy
strategy(ConnectionSettings.AffinityStrategy) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.Affinity: Set the ConnectionSettings.AffinityStrategy.
stream() - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder: Options for a consumer consuming from a stream.
stream() - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: Set the type to Management.QueueType.STREAM and return stream-specific specification.
STREAM - Enum constant in enum com.rabbitmq.client.amqp.Management.QueueType: Stream.
subject() - Method in interface com.rabbitmq.client.amqp.Message: Get the subject.
subject(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the message subject.
subscribe(String, Consumer.MessageHandler) - Method in interface com.rabbitmq.client.amqp.ObservationCollector: Decorate a Consumer.MessageHandler to observe the delivery of messages.
supportsContext(Observation.Context) - Method in interface com.rabbitmq.client.amqp.observation.micrometer.DeliverObservationConvention
supportsContext(Observation.Context) - Method in interface com.rabbitmq.client.amqp.observation.micrometer.PublishObservationConvention

T

TB(long) - Static method in class com.rabbitmq.client.amqp.ByteCapacity
TIMEOUT - Static variable in interface com.rabbitmq.client.amqp.BackOffDelayPolicy
tls() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: TLS settings.
to() - Method in interface com.rabbitmq.client.amqp.Message: Get the to field.
to(String) - Method in interface com.rabbitmq.client.amqp.Message: Set the to field.
toAddress() - Method in interface com.rabbitmq.client.amqp.Message: AddressBuilder for the Message.to() field.
toBytes() - Method in class com.rabbitmq.client.amqp.ByteCapacity
TOPIC - Enum constant in enum com.rabbitmq.client.amqp.Management.ExchangeType: Topic exchange type.
topology(boolean) - Method in interface com.rabbitmq.client.amqp.ConnectionBuilder.RecoveryConfiguration: Whether to activate topology recovery or not.
toString() - Method in class com.rabbitmq.client.amqp.Address
toString() - Method in class com.rabbitmq.client.amqp.BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy
toString() - Method in class com.rabbitmq.client.amqp.BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy
toString() - Method in class com.rabbitmq.client.amqp.ByteCapacity
trustEverything() - Method in interface com.rabbitmq.client.amqp.ConnectionSettings.TlsSettings: Convenience method to set a SSLContext that trusts all servers.
ttl() - Method in interface com.rabbitmq.client.amqp.Message: Get the message TTL.
ttl(Duration) - Method in interface com.rabbitmq.client.amqp.Message: Set the message TTL.
type() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo: The type of the queue.
type(Management.ExchangeType) - Method in interface com.rabbitmq.client.amqp.Management.ExchangeSpecification: Type of the exchange.
type(Management.QueueType) - Method in interface com.rabbitmq.client.amqp.Management.QueueSpecification: The type of the queue.
type(String) - Method in interface com.rabbitmq.client.amqp.Management.ExchangeSpecification: Type of the exchange (as a string, for non-built-in exchange types).

U

unbind() - Method in interface com.rabbitmq.client.amqp.Management: Start unbinding specification.
unbind() - Method in interface com.rabbitmq.client.amqp.Management.UnbindSpecification: Delete the binding.
unpause() - Method in interface com.rabbitmq.client.amqp.Consumer: Request to receive messages again.
unsettledMessageCount() - Method in interface com.rabbitmq.client.amqp.Consumer: Return the number of unsettled messages.
uri(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The URI of a node to connect to.
uris(String...) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: A list of URIs of nodes of the same cluster to use to connect to.
userId() - Method in interface com.rabbitmq.client.amqp.Message: Get user ID
userId(byte[]) - Method in interface com.rabbitmq.client.amqp.Message: Set the user ID.
username(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The username to use.
UsernamePasswordCredentialsProvider - Interface in com.rabbitmq.client.amqp: Contract for credentials based on a username/password pair.

V

V1 - Enum constant in enum com.rabbitmq.client.amqp.Management.ClassicQueueVersion: Classic queue version 1.
V2 - Enum constant in enum com.rabbitmq.client.amqp.Management.ClassicQueueVersion: Classic queue version 2.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.ConnectionSettings.Affinity.Operation: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.ConsumerBuilder.StreamOffsetSpecification: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Management.ClassicQueueVersion: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Management.ExchangeType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Management.OverFlowStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Management.QueueLeaderLocator: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Management.QueueType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Management.QuorumQueueDeadLetterStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.PublishDisposition: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.LowCardinalityTags: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Publisher.Status: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rabbitmq.client.amqp.Resource.State: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.rabbitmq.client.amqp.ConnectionSettings.Affinity.Operation: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.ConsumerBuilder.StreamOffsetSpecification: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Management.ClassicQueueVersion: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Management.ExchangeType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Management.OverFlowStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Management.QueueLeaderLocator: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Management.QueueType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Management.QuorumQueueDeadLetterStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.PublishDisposition: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.HighCardinalityTags: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation.LowCardinalityTags: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.observation.micrometer.AmqpObservationDocumentation: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Publisher.Status: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rabbitmq.client.amqp.Resource.State: Returns an array containing the constants of this enum type, in the order they are declared.
version() - Method in enum com.rabbitmq.client.amqp.Management.ClassicQueueVersion
version(Management.ClassicQueueVersion) - Method in interface com.rabbitmq.client.amqp.Management.ClassicQueueSpecification: Set the version of the classic queue implementation.
virtualHost(String) - Method in interface com.rabbitmq.client.amqp.ConnectionSettings: The virtual host to connect to.

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