Package io.micronaut.nats.reactive

Interface ReactivePublisher

All Known Implementing Classes:
ReactorReactivePublisher
public interface ReactivePublisher
A generic contract publishing message reactively.
Author:
jgrimm

  • Method Summary

    Modifier and Type
    Method
    Description
    org.reactivestreams.Publisher<Void>
    publish(io.nats.client.Message message)
    Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
    org.reactivestreams.Publisher<io.nats.client.Message>
    publishAndReply(io.nats.client.Message message)
    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

    • publish

      org.reactivestreams.Publisher<Void> publish(io.nats.client.Message message)
      Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
      Parameters:
      message - The message to publish
      Returns:
      the publisher

    • publishAndReply

      org.reactivestreams.Publisher<io.nats.client.Message> publishAndReply(io.nats.client.Message message)
      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:
      message - The message to publish
      Returns:
      The publisher of the received reply