Interface RabbitStreamOperations
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
RabbitStreamTemplate
Provides methods for sending messages using a RabbitMQ Stream producer.
- Since:
- 2.4
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidclose()org.springframework.util.concurrent.ListenableFuture<Boolean>convertAndSend(Object message) Convert to and send a Spring AMQP message.org.springframework.util.concurrent.ListenableFuture<Boolean>convertAndSend(Object message, org.springframework.amqp.core.MessagePostProcessor mpp) Convert to and send a Spring AMQP message.com.rabbitmq.stream.MessageBuilderReturn the producer'sMessageBuilderto create native stream messages.org.springframework.amqp.support.converter.MessageConverterReturn the message converter.org.springframework.util.concurrent.ListenableFuture<Boolean>send(com.rabbitmq.stream.Message message) Send a native stream message.org.springframework.util.concurrent.ListenableFuture<Boolean>send(org.springframework.amqp.core.Message message) Send a Spring AMQP message.Return the stream message converter.
-
Method Details
-
send
org.springframework.util.concurrent.ListenableFuture<Boolean> send(org.springframework.amqp.core.Message message) Send a Spring AMQP message.- Parameters:
message- the message.- Returns:
- a future to indicate success/failure.
-
convertAndSend
Convert to and send a Spring AMQP message.- Parameters:
message- the payload.- Returns:
- a future to indicate success/failure.
-
convertAndSend
org.springframework.util.concurrent.ListenableFuture<Boolean> convertAndSend(Object message, @Nullable org.springframework.amqp.core.MessagePostProcessor mpp) Convert to and send a Spring AMQP message. If aMessagePostProcessoris provided and returnsnull, the message is not sent and the future is completed withfalse.- Parameters:
message- the payload.mpp- a message post processor.- Returns:
- a future to indicate success/failure.
-
send
org.springframework.util.concurrent.ListenableFuture<Boolean> send(com.rabbitmq.stream.Message message) Send a native stream message.- Parameters:
message- the message.- Returns:
- a future to indicate success/failure.
- See Also:
-
messageBuilder
com.rabbitmq.stream.MessageBuilder messageBuilder()Return the producer'sMessageBuilderto create native stream messages.- Returns:
- the builder.
- See Also:
-
messageConverter
org.springframework.amqp.support.converter.MessageConverter messageConverter()Return the message converter.- Returns:
- the converter.
-
streamMessageConverter
StreamMessageConverter streamMessageConverter()Return the stream message converter.- Returns:
- the converter;
-
close
default void close() throws org.springframework.amqp.AmqpException- Specified by:
closein interfaceAutoCloseable- Throws:
org.springframework.amqp.AmqpException
-