Interface RabbitStreamOperations

  • All Superinterfaces:
    java.lang.AutoCloseable
    All Known Implementing Classes:
    RabbitStreamTemplate

    public interface RabbitStreamOperations
    extends java.lang.AutoCloseable
    Provides methods for sending messages using a RabbitMQ Stream producer.
    Since:
    2.4
    • Method Summary

      All Methods Instance Methods Abstract Methods Default Methods 
      Modifier and Type Method 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​(com.rabbitmq.stream.Message message)
      Send a native stream message.
      org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> send​(org.springframework.amqp.core.Message message)
      Send a Spring AMQP message.
      StreamMessageConverter streamMessageConverter()
      Return the stream message converter.
    • Method Detail

      • send

        org.springframework.util.concurrent.ListenableFuture<java.lang.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

        org.springframework.util.concurrent.ListenableFuture<java.lang.Boolean> convertAndSend​(java.lang.Object message)
        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<java.lang.Boolean> convertAndSend​(java.lang.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

        org.springframework.util.concurrent.ListenableFuture<java.lang.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()
      • messageBuilder

        com.rabbitmq.stream.MessageBuilder messageBuilder()
        Return the producer's MessageBuilder to create native stream messages.
        Returns:
        the builder.
        See Also:
        send(com.rabbitmq.stream.Message)
      • 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 java.lang.AutoCloseable
        Throws:
        org.springframework.amqp.AmqpException