Package io.smallrye.reactive.messaging.mqtt

Class MqttSink

java.lang.Object

io.smallrye.reactive.messaging.mqtt.MqttSink

public class MqttSink
extends Object

Constructor Summary

Constructors

Constructor	Description
MqttSink(io.vertx.mutiny.core.Vertx vertx, MqttConnectorOutgoingConfiguration config)

Method Summary

Modifier and Type	Method	Description
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	getSink()
boolean	isReady()

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttSink

public MqttSink(io.vertx.mutiny.core.Vertx vertx,
                MqttConnectorOutgoingConfiguration config)

Method Detail

getSink

public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> getSink()

isReady

public boolean isReady()