- send(Message) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Send a Spring AMQP message.
- 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 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 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
-
- 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
-
- setStreamConverter(StreamMessageConverter) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
-
- 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.
- 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.