All Classes and Interfaces
Class
Description
Customizer for
ConsumerBuilder.Default
StreamMessageConverter.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.