Interface RabbitStreamOperations

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
RabbitStreamTemplate
public interface RabbitStreamOperations extends AutoCloseable
Provides methods for sending messages using a RabbitMQ Stream producer.
Since:
2.4
Author:
Gary Russell

  • Method Details

    • send

      CompletableFuture<Boolean> send(Message message)
      Send a Spring AMQP message.
      Parameters:
      message - the message.
      Returns:
      a future to indicate success/failure.

    • convertAndSend

      CompletableFuture<Boolean> convertAndSend(Object message)
      Convert to and send a Spring AMQP message.
      Parameters:
      message - the payload.
      Returns:
      a future to indicate success/failure.

    • convertAndSend

      CompletableFuture<Boolean> convertAndSend(Object message, @Nullable MessagePostProcessor mpp)
      Convert to and send a Spring AMQP message. If a MessagePostProcessor is provided and returns null, the message is not sent and the future is completed with false.
      Parameters:
      message - the payload.
      mpp - a message post processor.
      Returns:
      a future to indicate success/failure.

    • send

      CompletableFuture<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's MessageBuilder to create native stream messages.
      Returns:
      the builder.
      See Also:

    • messageConverter

      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 AmqpException
      Specified by:
      close in interface AutoCloseable
      Throws:
      AmqpException