All Classes and Interfaces

Class
Description
Customizer for ConsumerBuilder.
Called to enable customization of the ProducerBuilder when a new producer is created.
Spring Rabbit Observation for stream listeners.
Default RabbitStreamListenerObservationConvention for Rabbit listener key values.
Low cardinality tags.
ObservationConvention for Rabbit stream listener key values.
ReceiverContext for stream Messages.
Default RabbitListenerObservationConvention for Rabbit listener key values.
SenderContext for Messages.
Provides methods for sending messages using a RabbitMQ Stream producer.
Default implementation of RabbitStreamOperations.
Spring RabbitMQ Observation for RabbitStreamTemplate.
Default RabbitStreamTemplateObservationConvention for Rabbit template key values.
Low cardinality tags.
ObservationConvention for Rabbit stream template key values.
Used to provision streams.
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.
Create Super Stream Topology Declarables.