Index

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

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

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.listener.StreamListenerContainer
Return the bean name.
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.
getCreationTime() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getCreationTime().
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.listener.StreamListenerContainer
The 'id' attribute of the listener.
getMessageListener() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
getReplyToGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
See Properties.getReplyToGroupId().
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

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

L

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.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

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.
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.
setAutoStartup(boolean) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
setBeanName(String) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
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).
setListenerId(String) - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
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.
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.
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).
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
 
stop() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
 
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.

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
 
C D E F G H I L M O P R S T 
All Classes and Interfaces|All Packages|Serialized Form