public interface RabbitStreamOperations extends AutoCloseable
| Modifier and Type | Method and Description |
|---|---|
default void |
close() |
ListenableFuture<Boolean> |
convertAndSend(Object message)
Convert to and send a Spring AMQP message.
|
ListenableFuture<Boolean> |
convertAndSend(Object message,
MessagePostProcessor mpp)
Convert to and send a Spring AMQP message.
|
com.rabbitmq.stream.MessageBuilder |
messageBuilder()
Return the producer's
MessageBuilder to create native stream messages. |
MessageConverter |
messageConverter()
Return the message converter.
|
ListenableFuture<Boolean> |
send(Message message)
Send a Spring AMQP message.
|
ListenableFuture<Boolean> |
send(com.rabbitmq.stream.Message message)
Send a native stream message.
|
StreamMessageConverter |
streamMessageConverter()
Return the stream message converter.
|
ListenableFuture<Boolean> send(Message message)
message - the message.ListenableFuture<Boolean> convertAndSend(Object message)
message - the payload.ListenableFuture<Boolean> convertAndSend(Object message, @Nullable MessagePostProcessor mpp)
MessagePostProcessor is
provided and returns null, the message is not sent and the future is
completed with false.message - the payload.mpp - a message post processor.ListenableFuture<Boolean> send(com.rabbitmq.stream.Message message)
message - the message.messageBuilder()com.rabbitmq.stream.MessageBuilder messageBuilder()
MessageBuilder to create native stream messages.send(com.rabbitmq.stream.Message)MessageConverter messageConverter()
StreamMessageConverter streamMessageConverter()
default void close()
throws AmqpException
close in interface AutoCloseableAmqpException