All Classes and Interfaces

Class	Description
Address	Utility class to represent a hostname and a port.
AddressBuilder<T>	Builder for a AMQP target address format v2.
AddressSelector	Contract to pick an Address to connect to a cluster node.
AmqpEnvironmentBuilder	Builder to create an Environment instance of the RabbitMQ AMQP 1.0 Java Client.
AmqpEnvironmentBuilder.EnvironmentConnectionSettings	Common settings for connections created by an environment instance.
AmqpException	Exception classes.
AmqpException.AmqpConnectionException	Exception related to connectivity problems.
AmqpException.AmqpEntityDoesNotExistException	Exception thrown when an entity (exchange, queue) does not exit.
AmqpException.AmqpResourceClosedException	Exception thrown when a resource is not usable because it is closed.
AmqpException.AmqpResourceInvalidStateException	Exception thrown when a resource is not in an appropriate state.
AmqpException.AmqpSecurityException	Exception related to security (authentication, permission, etc).
AmqpObservationDocumentation	To generate documentation.
AmqpObservationDocumentation.HighCardinalityTags	High cardinality tags.
AmqpObservationDocumentation.LowCardinalityTags	Low cardinality tags.
BackOffDelayPolicy	Contract to determine a delay between attempts of some task.
BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy	Policy with an initial delay for the first attempt, then a fixed delay, and a timeout.
BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy	Policy with an initial delay for the first attempt, then a fixed delay.
ByteCapacity	API to easily configure byte capacities.
Connection	A connection to the broker.
ConnectionBuilder	Builder for Connection instances.
ConnectionBuilder.RecoveryConfiguration	Configuration for recovery.
ConnectionSettings<T>	Settings for a connection.
ConnectionSettings.Affinity<T>	Connection affinity settings.
ConnectionSettings.Affinity.Operation	Affinity operation.
ConnectionSettings.AffinityContext	Context for the ConnectionSettings.AffinityStrategy.
ConnectionSettings.AffinityStrategy	Strategy to pick candidate nodes with an affinity with a queue.
ConnectionSettings.TlsSettings<T>	TLS settings.
Consumer	API to consume messages from a RabbitMQ queue.
Consumer.Context	Context for message processing.
Consumer.MessageHandler	Contract to process a message.
ConsumerBuilder	API to configure and create a Consumer.
ConsumerBuilder.StreamOffsetSpecification	Offset specification to start consuming from.
ConsumerBuilder.StreamOptions	Options for a consumer consuming from a stream.
CredentialsProvider	Marker interface for providing credentials.
DefaultProcessObservationConvention	Default ObservationConvention for processing (consuming).
DefaultPublishObservationConvention	Default ObservationConvention for publishing.
DefaultUsernamePasswordCredentialsProvider	Default implementation of UsernamePasswordCredentialsProvider.
DeliverContext	Delivery context.
DeliverObservationConvention	Contract for delivery (processing/consuming) ObservationConvention.
Environment	The Environment is the main entry point to a node or a cluster of nodes.
EnvironmentBuilder	Builder for Environment instances.
Management	API to manage AMQ 0.9.1 model topology (exchanges, queues, and bindings).
Management.BindingSpecification	Specification of a binding.
Management.ClassicQueueSpecification	Specification of a classic queue.
Management.ClassicQueueVersion	Classic queue version.
Management.ExchangeDeletion	Exchange deletion.
Management.ExchangeSpecification	Specification of an exchange.
Management.ExchangeType	Exchange type.
Management.OverFlowStrategy	Overflow strategy (when a queue reaches its maximum length limit).
Management.QueueDeletion	Queue deletion.
Management.QueueInfo	Queue information.
Management.QueueLeaderLocator	Queue leader locator.
Management.QueueSpecification	Specification to create a queue.
Management.QueueType	Queue Type.
Management.QuorumQueueDeadLetterStrategy	Dead letter strategy for quorum queues.
Management.QuorumQueueSpecification	Specification of a quorum queue.
Management.StreamSpecification	Specification of a stream.
Management.UnbindSpecification	Unbind specification.
Message	AMQP 1.0 message.
Message.MessageAddressBuilder	Message AddressBuilder.
MetricsCollector	Interface to collect execution data of the client.
MetricsCollector.ConsumeDisposition	The client-to-broker dispositions.
MetricsCollector.PublishDisposition	The broker-to-client dispositions.
MicrometerMetricsCollector	MetricsCollector implementation using Micrometer.
MicrometerObservationCollectorBuilder	Builder to create an instance of ObservationCollector using Micrometer observation.
NoOpMetricsCollector	No-operation implementation of MetricsCollector.
ObservationCollector	API to observe common message operations.
ObservationCollector.ConnectionInfo	Information on a connection.
PublishContext	Publish context.
Publisher	API to send messages.
Publisher.Callback	API to deal with the feedback the broker provides after its processing of a published message.
Publisher.Context	Feedback context.
Publisher.Status	Message status.
PublisherBuilder	API to configure and create a Publisher.
PublishObservationConvention	Contract for publishing ObservationConvention.
Resource	Marker interface for Resource-like classes.
Resource.Context	Context of a resource state change.
Resource.State	Resource state.
Resource.StateListener	Application listener for a Resource.
RpcClient	Client support class for RPC.
RpcClientBuilder	API to configure and create a RpcClient.
RpcClientBuilder.RpcClientAddressBuilder	Builder for the request address.
RpcServer	Client server class for RPC.
RpcServer.Context	Request processing context.
RpcServer.Handler	Contract to process a request message and return a reply message.
RpcServerBuilder	API to configure and create a RpcServer.
UsernamePasswordCredentialsProvider	Contract for credentials based on a username/password pair.