io.micronaut.configuration.rabbitmq.reactive

Interface ReactivePublisher

All Known Implementing Classes:

RxJavaReactivePublisher

public interface ReactivePublisher

A generic contract for publishing RabbitMQ messages reactively.

Since:

1.1.0

Author:

James Kleeh

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<java.lang.Void>	publish(RabbitPublishState publishState) Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
org.reactivestreams.Publisher<java.lang.Void>	publishAndConfirm(RabbitPublishState publishState) Publish the message with the provided arguments and return a reactive type that completes successfully when the broker acknowledged the message.
org.reactivestreams.Publisher<RabbitConsumerState>	publishAndReply(RabbitPublishState publishState) Publish the message with the provided arguments and return a reactive type that completes successfully when the reply is received from the reply to queue.

Method Detail

publishAndConfirm

org.reactivestreams.Publisher<java.lang.Void> publishAndConfirm(RabbitPublishState publishState)

Publish the message with the provided arguments and return a reactive type that completes successfully when the broker acknowledged the message.

Parameters:

publishState - The RabbitMQ publishing data

Returns:

The publisher

publish

org.reactivestreams.Publisher<java.lang.Void> publish(RabbitPublishState publishState)

Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.

Parameters:

publishState - The RabbitMQ publishing data

Returns:

The publisher

publishAndReply

org.reactivestreams.Publisher<RabbitConsumerState> publishAndReply(RabbitPublishState publishState)

Publish the message with the provided arguments and return a reactive type that completes successfully when the reply is received from the reply to queue.

Parameters:

publishState - The RabbitMQ publishing data

Returns:

The publisher of the received reply