Index

A B C D E F G H I L M O P R S T V 
All Classes and Interfaces|All Packages|Serialized Form

A

afterPropertiesSet() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 

B

BEAN_NAME - Enum constant in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.TemplateLowCardinalityTags
Bean name of the template.

C

close() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
 
close() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
ConsumerCustomizer - Interface in org.springframework.rabbit.stream.listener
Customizer for ConsumerBuilder.
convertAndSend(Object) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Convert to and send a Spring AMQP message.
convertAndSend(Object) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
convertAndSend(Object, MessagePostProcessor) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Convert to and send a Spring AMQP message.
convertAndSend(Object, MessagePostProcessor) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
createContainerInstance() - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
Create an instance of the listener container.
createListenerContainer(RabbitListenerEndpoint) - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
 
createRecoverer() - Method in class org.springframework.rabbit.stream.retry.StreamRetryOperationsInterceptorFactoryBean
 

D

DefaultRabbitListenerObservationConvention() - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention
 
DefaultRabbitStreamListenerObservationConvention() - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention
 
DefaultRabbitStreamTemplateObservationConvention() - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention
 
DefaultStreamMessageConverter - Class in org.springframework.rabbit.stream.support.converter
DefaultStreamMessageConverter() - Constructor for class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
Construct an instance using a WrapperMessageBuilder.
DefaultStreamMessageConverter(Codec) - Constructor for class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
Construct an instance using the provided codec.

E

equals(Object) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
 

F

fromMessage(Message) - Method in class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
 
fromMessage(Message) - Method in interface org.springframework.rabbit.stream.support.converter.StreamMessageConverter
 

G

getBeanName() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageSenderContext
 
getConfirmationCode() - Method in exception org.springframework.rabbit.stream.producer.StreamSendException
Return the confirmation code, if available.
getContext() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
Return the stream MessageHandler.Context for the message.
getContextualName(RabbitMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention
 
getContextualName(RabbitStreamMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention
 
getContextualName(RabbitStreamMessageSenderContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention
 
getCreationTime() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getCreationTime().
getDestination() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageSenderContext
Return the destination - exchange/routingKey.
getGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getGroupId().
getGroupSequence() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getGroupSequence().
getListenerId() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext
 
getLowCardinalityKeyValues(RabbitMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention
 
getLowCardinalityKeyValues(RabbitStreamMessageReceiverContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention
 
getLowCardinalityKeyValues(RabbitStreamMessageSenderContext) - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention
 
getMessageListener() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
getName() - Method in interface org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservationConvention
 
getName() - Method in interface org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservationConvention
 
getPhase() - Method in class org.springframework.rabbit.stream.support.StreamAdmin
 
getReplyToGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getReplyToGroupId().
getSource() - Method in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext
Return the source (stream) for this message.
getStreamConverter() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Get a StreamMessageConverter used to convert a Message to a Message.
getSubject() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getSubject().
getTo() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getTo().

H

hashCode() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
 

I

INSTANCE - Static variable in class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention
A singleton instance of the convention.
INSTANCE - Static variable in class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention
A singleton instance of the convention.
INSTANCE - Static variable in class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention
A singleton instance of the convention.
isAutoStartup() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
isAutoStartup() - Method in class org.springframework.rabbit.stream.support.StreamAdmin
 
isRunning() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
isRunning() - Method in class org.springframework.rabbit.stream.support.StreamAdmin
 

L

LISTENER_ID - Enum constant in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.ListenerLowCardinalityTags
Listener id.
logger - Variable in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
logger - Variable in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 

M

messageBuilder() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Return the producer's MessageBuilder to create native stream messages.
messageBuilder() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
messageConverter() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Return the message converter.
messageConverter() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 

O

onStreamMessage(Message, MessageHandler.Context) - Method in class org.springframework.rabbit.stream.listener.adapter.StreamMessageListenerAdapter
 
onStreamMessage(Message, MessageHandler.Context) - Method in interface org.springframework.rabbit.stream.listener.StreamMessageListener
Process a message.
org.springframework.rabbit.stream.config - package org.springframework.rabbit.stream.config
Provides classes for stream listener configuration.
org.springframework.rabbit.stream.listener - package org.springframework.rabbit.stream.listener
Provides classes for stream listeners.
org.springframework.rabbit.stream.listener.adapter - package org.springframework.rabbit.stream.listener.adapter
Provides classes for stream listener adapters.
org.springframework.rabbit.stream.micrometer - package org.springframework.rabbit.stream.micrometer
Provides classes for Micrometer support.
org.springframework.rabbit.stream.producer - package org.springframework.rabbit.stream.producer
Provides classes for stream producers.
org.springframework.rabbit.stream.retry - package org.springframework.rabbit.stream.retry
Provides classes supporting retries.
org.springframework.rabbit.stream.support - package org.springframework.rabbit.stream.support
Provides support classes.
org.springframework.rabbit.stream.support.converter - package org.springframework.rabbit.stream.support.converter
Provides classes for message conversion.

P

ProducerCustomizer - Interface in org.springframework.rabbit.stream.producer
Called to enable customization of the ProducerBuilder when a new producer is created.

R

RabbitStreamListenerObservation - Enum Class in org.springframework.rabbit.stream.micrometer
Spring Rabbit Observation for stream listeners.
RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention - Class in org.springframework.rabbit.stream.micrometer
Default RabbitStreamListenerObservationConvention for Rabbit listener key values.
RabbitStreamListenerObservation.ListenerLowCardinalityTags - Enum Class in org.springframework.rabbit.stream.micrometer
Low cardinality tags.
RabbitStreamListenerObservationConvention - Interface in org.springframework.rabbit.stream.micrometer
ObservationConvention for Rabbit stream listener key values.
RabbitStreamMessageReceiverContext - Class in org.springframework.rabbit.stream.micrometer
ReceiverContext for stream Messages.
RabbitStreamMessageReceiverContext(Message, String, String) - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext
 
RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention - Class in org.springframework.rabbit.stream.micrometer
Default RabbitListenerObservationConvention for Rabbit listener key values.
RabbitStreamMessageSenderContext - Class in org.springframework.rabbit.stream.micrometer
SenderContext for Messages.
RabbitStreamMessageSenderContext(Message, String, String) - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageSenderContext
 
RabbitStreamOperations - Interface in org.springframework.rabbit.stream.producer
Provides methods for sending messages using a RabbitMQ Stream producer.
RabbitStreamTemplate - Class in org.springframework.rabbit.stream.producer
Default implementation of RabbitStreamOperations.
RabbitStreamTemplate(Environment, String) - Constructor for class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Construct an instance with the provided Environment.
RabbitStreamTemplateObservation - Enum Class in org.springframework.rabbit.stream.micrometer
Spring RabbitMQ Observation for RabbitStreamTemplate.
RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention - Class in org.springframework.rabbit.stream.micrometer
Default RabbitStreamTemplateObservationConvention for Rabbit template key values.
RabbitStreamTemplateObservation.TemplateLowCardinalityTags - Enum Class in org.springframework.rabbit.stream.micrometer
Low cardinality tags.
RabbitStreamTemplateObservationConvention - Interface in org.springframework.rabbit.stream.micrometer
ObservationConvention for Rabbit stream template key values.
recover(Message, MessageHandler.Context, Throwable) - Method in interface org.springframework.rabbit.stream.retry.StreamMessageRecoverer
Callback for message that was consumed but failed all retry attempts.
recover(Message, Throwable) - Method in interface org.springframework.rabbit.stream.retry.StreamMessageRecoverer
 

S

send(Message) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Send a native stream message.
send(Message) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
send(Message) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Send a Spring AMQP message.
send(Message) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
setAdviceChain(Advice...) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Set an advice chain to apply to the listener.
setApplicationContext(ApplicationContext) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
setAutoStartup(boolean) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
setAutoStartup(boolean) - Method in class org.springframework.rabbit.stream.support.StreamAdmin
Set to false to prevent automatic startup.
setBeanName(String) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
setBuilderSupplier(Supplier<MessageBuilder>) - Method in class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
Set a supplier for a message builder.
setConsumerCustomizer(ConsumerCustomizer) - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
Customize the consumer builder before it is built.
setConsumerCustomizer(ConsumerCustomizer) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Customize the consumer builder before it is built.
setContainerCustomizer(ContainerCustomizer<StreamListenerContainer>) - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
Set a ContainerCustomizer that is invoked after a container is created and configured to enable further customization of the container.
setCreationTime(long) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See MessageBuilder.PropertiesBuilder.creationTime(long).
setGroupId(String) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See MessageBuilder.PropertiesBuilder.groupId(String).
setGroupSequence(long) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See MessageBuilder.PropertiesBuilder.groupSequence(long).
setMessageConverter(MessageConverter) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Set a converter for RabbitStreamTemplate.convertAndSend(Object) operations.
setMessageRecoverer(MessageRecoverer) - Method in class org.springframework.rabbit.stream.retry.StreamRetryOperationsInterceptorFactoryBean
 
setNativeListener(boolean) - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
Set to true to create a container supporting a native RabbitMQ Stream message.
setObservationConvention(RabbitStreamListenerObservationConvention) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Set a RabbitStreamListenerObservationConvention; used to add additional key/values to observations when using a StreamMessageListener.
setObservationEnabled(boolean) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Set to true to enable Micrometer observation.
setPhase(int) - Method in class org.springframework.rabbit.stream.support.StreamAdmin
Set the phase; default is 0.
setProducerCustomizer(ProducerCustomizer) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Used to customize the ProducerBuilder before the Producer is built.
setQueueNames(String...) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
setReplyToGroupId(String) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See MessageBuilder.PropertiesBuilder.replyToGroupId(String).
setStreamConverter(StreamMessageConverter) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Set a StreamMessageConverter used to convert a Message to a Message.
setStreamConverter(StreamMessageConverter) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Set a converter to convert from Message to Message for RabbitStreamTemplate.send(Message) and RabbitStreamTemplate.convertAndSend(Object) methods.
setStreamListenerObservationConvention(RabbitStreamListenerObservationConvention) - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
Set a RabbitStreamListenerObservationConvention that is used when receiving native stream messages.
setStreamMessageRecoverer(StreamMessageRecoverer) - Method in class org.springframework.rabbit.stream.retry.StreamRetryOperationsInterceptorFactoryBean
Set a StreamMessageRecoverer to call when retries are exhausted.
setSubject(String) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See MessageBuilder.PropertiesBuilder.subject(String).
setSuperStreamRouting(Function<Message, String>) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Add a routing function, making the stream a super stream.
setTo(String) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See MessageBuilder.PropertiesBuilder.to(String).
setupMessageListener(MessageListener) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
start() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
start() - Method in class org.springframework.rabbit.stream.support.StreamAdmin
 
stop() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
stop() - Method in class org.springframework.rabbit.stream.support.StreamAdmin
 
STREAM_LISTENER_OBSERVATION - Enum constant in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation
Observation for Rabbit stream listeners.
STREAM_TEMPLATE_OBSERVATION - Enum constant in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation
Observation for RabbitStreamTemplates.
StreamAdmin - Class in org.springframework.rabbit.stream.support
Used to provision streams.
StreamAdmin(Environment, Consumer<StreamCreator>) - Constructor for class org.springframework.rabbit.stream.support.StreamAdmin
Construct with the provided parameters.
StreamListenerContainer - Class in org.springframework.rabbit.stream.listener
A listener container for RabbitMQ Streams.
StreamListenerContainer(Environment) - Constructor for class org.springframework.rabbit.stream.listener.StreamListenerContainer
Construct an instance using the provided environment.
StreamListenerContainer(Environment, Codec) - Constructor for class org.springframework.rabbit.stream.listener.StreamListenerContainer
Construct an instance using the provided environment and codec.
streamMessageConverter() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
Return the stream message converter.
streamMessageConverter() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
 
StreamMessageConverter - Interface in org.springframework.rabbit.stream.support.converter
Converts between Message and Message.
StreamMessageListener - Interface in org.springframework.rabbit.stream.listener
A message listener that receives native stream messages.
StreamMessageListenerAdapter - Class in org.springframework.rabbit.stream.listener.adapter
A listener adapter that receives native stream messages.
StreamMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler) - Constructor for class org.springframework.rabbit.stream.listener.adapter.StreamMessageListenerAdapter
Construct an instance with the provided arguments.
StreamMessageProperties - Class in org.springframework.rabbit.stream.support
MessageProperties extension for stream messages.
StreamMessageProperties() - Constructor for class org.springframework.rabbit.stream.support.StreamMessageProperties
Create a new instance.
StreamMessageProperties(MessageHandler.Context) - Constructor for class org.springframework.rabbit.stream.support.StreamMessageProperties
Create a new instance with the provided context.
StreamMessageRecoverer - Interface in org.springframework.rabbit.stream.retry
Implementations of this interface can handle failed messages after retries are exhausted.
StreamRabbitListenerContainerFactory - Class in org.springframework.rabbit.stream.config
Factory for StreamListenerContainer.
StreamRabbitListenerContainerFactory(Environment) - Constructor for class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
Construct an instance using the provided environment.
StreamRetryOperationsInterceptorFactoryBean - Class in org.springframework.rabbit.stream.retry
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.
StreamRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.rabbit.stream.retry.StreamRetryOperationsInterceptorFactoryBean
 
StreamSendException - Exception in org.springframework.rabbit.stream.producer
Used to complete the future exceptionally when sending fails.
StreamSendException(String, int) - Constructor for exception org.springframework.rabbit.stream.producer.StreamSendException
Construct an instance with the provided message.
superStream(String, String) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Enable Single Active Consumer on a Super Stream, with one consumer.
superStream(String, String, int) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
Enable Single Active Consumer on a Super Stream with the provided number of consumers.
SuperStream - Class in org.springframework.rabbit.stream.config
Create Super Stream Topology Declarables.
SuperStream(String, int) - Constructor for class org.springframework.rabbit.stream.config.SuperStream
Create a Super Stream with the provided parameters.
SuperStream(String, int, BiFunction<String, Integer, List<String>>) - Constructor for class org.springframework.rabbit.stream.config.SuperStream
Create a Super Stream with the provided parameters.
supportsContext(Observation.Context) - Method in interface org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservationConvention
 
supportsContext(Observation.Context) - Method in interface org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservationConvention
 

T

toMessage(Object, MessageProperties) - Method in interface org.springframework.rabbit.stream.support.converter.StreamMessageConverter
 
toMessage(Object, StreamMessageProperties) - Method in class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
 
toMessage(Object, StreamMessageProperties) - Method in interface org.springframework.rabbit.stream.support.converter.StreamMessageConverter
 

V

valueOf(String) - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.ListenerLowCardinalityTags
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.TemplateLowCardinalityTags
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation
Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation.ListenerLowCardinalityTags
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamListenerObservation
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.TemplateLowCardinalityTags
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation
Returns an array containing the constants of this enum class, in the order they are declared.
A B C D E F G H I L M O P R S T V 
All Classes and Interfaces|All Packages|Serialized Form