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 the message with the provided arguments and return a reactive type that completes successfully when the message is published.
    org.reactivestreams.Publisher<Void>
    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>
    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