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
  • Method Details

    • send

      CompletableFuture<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

      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 org.springframework.amqp.core.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

      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:
      close in interface AutoCloseable
      Throws:
      org.springframework.amqp.AmqpException