io.micronaut.nats.reactive

Interface ReactivePublisher

All Known Implementing Classes:

RxJavaReactivePublisher

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(PublishState publishState) 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(PublishState 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 Detail

publish

org.reactivestreams.Publisher<java.lang.Void> publish(PublishState publishState)

Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.

Parameters:

publishState - The publishing data

Returns:

the publisher

publishAndReply

org.reactivestreams.Publisher<io.nats.client.Message> publishAndReply(PublishState 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 publishing data

Returns:

The publisher of the received reply