Package org.springframework.rabbit.stream.producer

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
    Author:
    Gary Russell

    • Method Detail

      • send

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

      • convertAndSend

        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

        ListenableFuture<java.lang.Boolean> convertAndSend​(java.lang.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

        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

        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 java.lang.AutoCloseable
        Throws:
        AmqpException