All Classes and Interfaces
Class
Description
Utility class to represent a hostname and a port.
API to potentially change resolved node address to connect to
The
ANONYMOUS SaslMechanism.Exception to report a failed authentication attempt.
Contract to determine a delay between attempts of some task.
API to easily configure byte capacities.
API to check the content of message chunks.
Indicate a checksum error for a chunk.
This is low-level client API to communicate with the broker.
Codec to encode and decode messages.
CompressionCodecFactory creating codecs using Apache Commons Compress
implementations.Enum to define types of compression codecs.
Codec to compress and decompress sub-entries.
Factory to create
CompressionCodec instances.Exception thrown when an error during compression/decompression occurs.
Implementation of
CompressionCodecs.Callback API to confirm or fail a message.
The status to confirm or fail a message.
Various constants (response codes, errors, etc)
API to consume messages from a RabbitMQ Stream.
API to configure and create a
Consumer.Auto-tracking strategy.
Filter configuration.
Message flow configuration.
Manual tracking strategy.
Contract to determine when a subscription provides credits to get more messages.
Chunk context.
Strategy that provides the specified number of initial credits and a credit on each new chunk.
Strategy that provides the specified number of initial credits and a credit when the specified
ratio of the chunk messages are processed.
Behavior for
MessageHandler.Context.processed() calls.An interface for reacting to status changes of single active consumers.
Information on the status change.
Marker interface for providing credentials.
CompressionCodecFactory implementation using various compression libraries.Default
ProcessObservationConvention.Default
PublishObservationConvention.SaslConfiguration that supports our built-in mechanisms.Default implementation of
UsernamePasswordCredentialsProvider.The
Environment is the main entry point to a node or a cluster of nodes.API to configure and create an
Environment.Helper to configure Netty
Helper to configure TLS.
The
EXTERNAL SaslMechanism.SaslConfiguration using the JDK SASL support.API for outbound and inbound messages.
API to configure and create a
Message.API to set application properties.
API to set message annotations.
API to set message properties.
Callback API for inbound messages.
Information about the message.
Builder to configure and create Micrometer
Observation implementation of
ObservationCollector.API to instrument operations in the stream client.
API to specify an offset in a stream.
The
PLAIN SaslMechanism.Observation.Context for RabbitMQ Stream consuming.ObservationConvention for RabbitMQ Stream consuming.API to send messages to a RabbitMQ Stream.
API to create and configure a
Producer.Routing configuration for super streams (partitioned streams).
Message properties.
Observation.Context for RabbitMQ Stream publishing.ObservationConvention for RabbitMQ Stream consuming.Strategy to route outbound messages to appropriate streams.
Metadata on the super stream.
Contract to choose a
SaslMechanism from the ones supported by the server.Contract to handle SASL challenges sent by a SASL server.
API to configure and create a stream.
The leader locator strategy.
Super stream configuration.
Exception to indicate a stream does not exist.
Generic stream exception.
Exception to indicate a stream is not available.
ObservationDocumentation for RabbitMQ Stream.High cardinality tags.
Low cardinality tags.
Statistics on a stream.
Callback interface to customize a subscription.
Context object for the subscription.
This code is based on QPid Proton's
UnsignedByte class.This code is based on QPid Proton's
UnsignedInteger class.This code is based on QPid Proton's
UnsignedLong class.This code is based on QPid Proton's
UnsignedShort class.Contract for credentials based on a username/password pair.