Package io.micronaut.rabbitmq.reactive
Interface ReactivePublisher
- All Known Implementing Classes:
ReactorReactivePublisher
public interface ReactivePublisher
A generic contract for publishing RabbitMQ messages reactively.
- Since:
- 1.1.0
- Author:
- James Kleeh
-
Method Summary
Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher<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<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 Details
-
publishAndConfirm
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
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
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
-