Interface ReactivePublisher
public interface ReactivePublisher
A generic contract publishing message reactively.
- Since:
- 4.0.0
- Author:
- Joachim Grimm
-
Method Summary
Modifier and TypeMethodDescriptionorg.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 publishoptions
- the publish options- Returns:
- the publisher
-