Package io.micronaut.nats.jetstream.reactive

Interface ReactivePublisher

public interface ReactivePublisher
A generic contract publishing message reactively.
Since:
4.0.0
Author:
Joachim Grimm

  • Method Summary

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

  • Method Details

    • publish

      org.reactivestreams.Publisher<io.nats.client.api.PublishAck> 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

    • publish

      org.reactivestreams.Publisher<io.nats.client.api.PublishAck> publish(io.nats.client.Message message, io.nats.client.PublishOptions options)
      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
      options - the publish options
      Returns:
      the publisher