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 Type
    Method
    Description
    org.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

      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.
      Parameters:
      publishState - The RabbitMQ publishing data
      Returns:
      The publisher

    • publish

      org.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.
      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