Index
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
D
- DefaultStreamMessageConverter - Class in org.springframework.rabbit.stream.support.converter
-
Default
StreamMessageConverter. - 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.Contextfor 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
- 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
MessageBuilderto 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.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
ProducerBuilderwhen 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.
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
- 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
ContainerCustomizerthat 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. - 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
ProducerBuilderbefore theProduceris 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
- setStreamConverter(StreamMessageConverter) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
-
Set a converter to convert from
MessagetoMessageforRabbitStreamTemplate.send(Message)andRabbitStreamTemplate.convertAndSend(Object)methods. - 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
MessageandMessage. - 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
-
MessagePropertiesextension 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.
- 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.
- 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
All Classes and Interfaces|All Packages|Serialized Form