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 and Description
org.reactivestreams.Publisher<java.lang.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 Detail

publish

org.reactivestreams.Publisher<java.lang.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