io.micronaut.nats.reactive

Class ReactorReactivePublisher

java.lang.Object

io.micronaut.nats.reactive.ReactorReactivePublisher

All Implemented Interfaces:

ReactivePublisher

@Internal
 @EachBean(value=io.nats.client.Connection.class)
public class ReactorReactivePublisher
extends java.lang.Object
implements ReactivePublisher

Author:

jgrimm

Constructor Summary

Constructors

Constructor and Description
ReactorReactivePublisher(io.nats.client.Connection connection) Constructor.

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReactorReactivePublisher

public ReactorReactivePublisher(@Parameter
                                io.nats.client.Connection connection)

Constructor.

Parameters:

connection - The given connection

Method Detail

publish

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

Description copied from interface: ReactivePublisher

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

Specified by:

publish in interface ReactivePublisher

Parameters:

publishState - The publishing data

Returns:

the publisher

publishAndReply

public org.reactivestreams.Publisher<io.nats.client.Message> publishAndReply(PublishState publishState)

Description copied from interface: ReactivePublisher

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.

Specified by:

publishAndReply in interface ReactivePublisher

Parameters:

publishState - The publishing data

Returns:

The publisher of the received reply