Index
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.ConsumerBuilder.FilterOptions
-
Filter on absolute expiry time field.
- 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
- ACCEPTED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.PublishDisposition
- 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 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
- 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
- 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.FilterOptions<T> - Interface in com.rabbitmq.client.amqp
-
Filter options for support of AMQP filter expressions.
- ConsumerBuilder.StreamFilterOptions - Interface in com.rabbitmq.client.amqp
-
Filter options for support of AMQP filter expressions.
- 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.
- ConsumerBuilder.SubscriptionListener - Interface in com.rabbitmq.client.amqp
-
Callback to modify a consumer subscription before the link creation.
- ConsumerBuilder.SubscriptionListener.Context - Interface in com.rabbitmq.client.amqp
-
Subscription context.
- 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
-
Deprecated, for removal: This API element is subject to removal in a future version.Do not use anymore
- contentEncoding() - Method in interface com.rabbitmq.client.amqp.Message
-
Get the content-encoding.
- contentEncoding(String) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.FilterOptions
-
Filter on content-encoding field.
- 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.ConsumerBuilder.FilterOptions
-
Filter on content-type field.
- 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.ConsumerBuilder.FilterOptions
-
Filter on correlation ID.
- 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.ConsumerBuilder.FilterOptions
-
Filter on correlation ID.
- 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.ConsumerBuilder.FilterOptions
-
Filter on correlation ID.
- correlationId(Object) - Method in interface com.rabbitmq.client.amqp.Message
-
Set the message correlation ID.
- correlationId(String) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.FilterOptions
-
Filter on 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.ConsumerBuilder.FilterOptions
-
Filter on correlation ID.
- 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.ConsumerBuilder.FilterOptions
-
Filter on creation time field.
- 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). - discard(Map<String, Object>) - Method in interface com.rabbitmq.client.amqp.Consumer.Context
-
Discard the message with annotations to combine with the existing message annotations.
- DISCARDED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition
- 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.
- filter() - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions
-
Options for AMQP filter expressions.
- 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 for stream filtering.
- 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.ConsumerBuilder.FilterOptions
-
Filter on 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.ConsumerBuilder.FilterOptions
-
Filter on group sequence.
- 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
-
Deprecated, for removal: This API element is subject to removal in a future version.
- initialCredits(int) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder
-
The initial number credits to grant to the AMQP receiver.
- initialMemberCount(int) - Method in interface com.rabbitmq.client.amqp.Management.QuorumQueueSpecification
-
Set the number of initial members the quorum queue should have.
- initialMemberCount(int) - Method in interface com.rabbitmq.client.amqp.Management.StreamSpecification
-
Set the number of initial members the stream should have.
- 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.StateListener
s to the connection. - listeners(Resource.StateListener...) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder
-
Add
Resource.StateListener
s to the consumer. - listeners(Resource.StateListener...) - Method in interface com.rabbitmq.client.amqp.PublisherBuilder
-
Add
Resource.StateListener
s 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
- members() - Method in interface com.rabbitmq.client.amqp.Management.QueueInfo
-
The nodes the queue has members on.
- 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.ConsumerBuilder.FilterOptions
-
Filter on message ID.
- 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.ConsumerBuilder.FilterOptions
-
Filter on message ID.
- messageId(long) - Method in interface com.rabbitmq.client.amqp.Message
-
Set the message ID (long).
- messageId(Object) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.FilterOptions
-
Filter on message ID.
- messageId(Object) - Method in interface com.rabbitmq.client.amqp.Message
-
Set the message ID.
- messageId(String) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.FilterOptions
-
Filter on 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.ConsumerBuilder.FilterOptions
-
Filter on message ID.
- 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.
- preSubscribe(ConsumerBuilder.SubscriptionListener.Context) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.SubscriptionListener
-
Pre-subscription callback.
- 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.ConsumerBuilder.FilterOptions
-
Filter on boolean 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.ConsumerBuilder.FilterOptions
-
Filter on byte 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.ConsumerBuilder.FilterOptions
-
Filter on byte array 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.ConsumerBuilder.FilterOptions
-
Filter on character 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.ConsumerBuilder.FilterOptions
-
Filter on double 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.ConsumerBuilder.FilterOptions
-
Filter on float 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.ConsumerBuilder.FilterOptions
-
Filter on integer 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.ConsumerBuilder.FilterOptions
-
Filter on long 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.ConsumerBuilder.FilterOptions
-
Filter on short 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.ConsumerBuilder.FilterOptions
-
Filter on string 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.ConsumerBuilder.FilterOptions
-
Filter on UUID 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.ConsumerBuilder.FilterOptions
-
Filter on 128-bit decimal number 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.ConsumerBuilder.FilterOptions
-
Filter on 32-bit decimal number 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.ConsumerBuilder.FilterOptions
-
Filter on 64-bit decimal number 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.ConsumerBuilder.FilterOptions
-
Filter on symbol 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.ConsumerBuilder.FilterOptions
-
Filter on timestamp 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.ConsumerBuilder.FilterOptions
-
Filter on unsigned byte 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.ConsumerBuilder.FilterOptions
-
Filter on unsigned integer 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.ConsumerBuilder.FilterOptions
-
Filter on unsigned long 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.ConsumerBuilder.FilterOptions
-
Filter on unsigned short 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
-
Deprecated, for removal: This API element is subject to removal in a future version.
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
- 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
- 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
-
Deprecated, for removal: This API element is subject to removal in a future version.
- 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.ConsumerBuilder.FilterOptions
-
Filter on 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 theMessage.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.ConsumerBuilder.FilterOptions
-
Filter on reply-to group.
- 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). - requeue(Map<String, Object>) - Method in interface com.rabbitmq.client.amqp.Consumer.Context
-
Requeue the message with annotations to combine with the existing message annotations.
- REQUEUED - Enum constant in enum com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition
- 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.ConsumerBuilder.StreamFilterOptions
-
Go back to the stream options.
- 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.
- streamOptions() - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.SubscriptionListener.Context
-
Stream options, to set the offset to start consuming from.
- subject() - Method in interface com.rabbitmq.client.amqp.Message
-
Get the subject.
- subject(String) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder.FilterOptions
-
Filter on subject field.
- 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. - subscriptionListener(ConsumerBuilder.SubscriptionListener) - Method in interface com.rabbitmq.client.amqp.ConsumerBuilder
-
Set a listener to customize the subscription before the consumer is created (or recovered).
- 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.ConsumerBuilder.FilterOptions
-
Filter on 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 theMessage.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.ConsumerBuilder.FilterOptions
-
Filter on 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.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form