Package com.rabbitmq.client.amqp
package com.rabbitmq.client.amqp
Main API for the RabbitMQ AMQP Java Client.
-
ClassDescriptionUtility class to represent a hostname and a port.Builder for a AMQP target address format v2.Contract to pick an
Address
to connect to a cluster node.Exception classes.Exception related to connectivity problems.Exception thrown when an entity (exchange, queue) does not exit.Exception thrown when a resource is not usable because it is closed.Exception thrown when a resource is not in an appropriate state.Exception related to security (authentication, permission, etc).Contract to determine a delay between attempts of some task.Policy with an initial delay for the first attempt, then a fixed delay, and a timeout.Policy with an initial delay for the first attempt, then a fixed delay.API to easily configure byte capacities.A connection to the broker.Builder forConnection
instances.Configuration for recovery.Settings for a connection.Connection affinity settings.Affinity operation.Context for theConnectionSettings.AffinityStrategy
.Strategy to pick candidate nodes with an affinity with a queue.TLS settings.API to consume messages from a RabbitMQ queue.Context for message processing.Contract to process a message.API to configure and create aConsumer
.Filter options for support of AMQP filter expressions.Filter options for support of AMQP filter expressions.Offset specification to start consuming from.Options for a consumer consuming from a stream.Callback to modify a consumer subscription before the link creation.Subscription context.Marker interface for providing credentials.Default implementation ofUsernamePasswordCredentialsProvider
.TheEnvironment
is the main entry point to a node or a cluster of nodes.Builder forEnvironment
instances.API to manage AMQ 0.9.1 model topology (exchanges, queues, and bindings).Specification of a binding.Specification of a classic queue.Classic queue version.Exchange deletion.Specification of an exchange.Exchange type.Overflow strategy (when a queue reaches its maximum length limit).Queue deletion.Queue information.Queue leader locator.Specification to create a queue.Queue Type.Dead letter strategy for quorum queues.Specification of a quorum queue.Specification of a stream.Unbind specification.AMQP 1.0 message.MessageAddressBuilder
.Configuration to retrieve a token using the OAuth 2 Client Credentials flow.TLS settings to request the OAuth 2 token.API to observe common message operations.Information on a connection.API to send messages.API to deal with the feedback the broker provides after its processing of a published message.Feedback context.Message status.API to configure and create aPublisher
.Marker interface forResource
-like classes.Context of a resource state change.Resource state.Application listener for aResource
.Client support class for RPC.API to configure and create aRpcClient
.Builder for the request address.Client server class for RPC.Request processing context.Contract to process a request message and return a reply message.API to configure and create aRpcServer
.Contract for credentials based on a username/password pair.