public interface RabbitStreamOperations
extends java.lang.AutoCloseable
| Modifier and Type | Method and Description |
|---|---|
default void |
close() |
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
convertAndSend(java.lang.Object message)
Convert to and send a Spring AMQP message.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
convertAndSend(java.lang.Object message,
org.springframework.amqp.core.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. |
org.springframework.amqp.support.converter.MessageConverter |
messageConverter()
Return the message converter.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
send(org.springframework.amqp.core.Message message)
Send a Spring AMQP message.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> |
send(com.rabbitmq.stream.Message message)
Send a native stream message.
|
StreamMessageConverter |
streamMessageConverter()
Return the stream message converter.
|
org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> send(org.springframework.amqp.core.Message message)
message - the message.org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> convertAndSend(java.lang.Object message)
message - the payload.org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> convertAndSend(java.lang.Object message,
@Nullable
org.springframework.amqp.core.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.org.springframework.util.concurrent.ListenableFuture<java.lang.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)org.springframework.amqp.support.converter.MessageConverter messageConverter()
StreamMessageConverter streamMessageConverter()
default void close()
throws org.springframework.amqp.AmqpException
close in interface java.lang.AutoCloseableorg.springframework.amqp.AmqpException