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