org.springframework.rabbit.stream.producer

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 Summary

Modifier and Type	Method and Description
default void	close()
ListenableFuture<Boolean>	convertAndSend(Object message) Convert to and send a Spring AMQP message.
ListenableFuture<Boolean>	convertAndSend(Object message, 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.
MessageConverter	messageConverter() Return the message converter.
ListenableFuture<Boolean>	send(Message message) Send a Spring AMQP message.
ListenableFuture<Boolean>	send(com.rabbitmq.stream.Message message) Send a native stream message.
StreamMessageConverter	streamMessageConverter() Return the stream message converter.

Method Detail

send

ListenableFuture<Boolean> send(Message message)

Send a Spring AMQP message.

Parameters:

message - the message.

Returns:

a future to indicate success/failure.

convertAndSend

ListenableFuture<Boolean> convertAndSend(Object message)

Convert to and send a Spring AMQP message.

Parameters:

message - the payload.

Returns:

a future to indicate success/failure.

convertAndSend

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

ListenableFuture<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 AutoCloseable

Throws:

AmqpException