All Classes and Interfaces

Class
Description
Customizer for ConsumerBuilder.
Called to enable customization of the ProducerBuilder when a new producer is created.
Provides methods for sending messages using a RabbitMQ Stream producer.
Default implementation of RabbitStreamOperations.
A listener container for RabbitMQ Streams.
Converts between Message and Message.
A message listener that receives native stream messages.
A listener adapter that receives native stream messages.
MessageProperties extension for stream messages.
Implementations of this interface can handle failed messages after retries are exhausted.
Factory for StreamListenerContainer.
Convenient factory bean for creating a stateless retry interceptor for use in a StreamListenerContainer when consuming native stream messages, giving you a large amount of control over the behavior of a container when a listener fails.
Used to complete the future exceptionally when sending fails.