io.smallrye.reactive.messaging.mqtt

Class MqttSource

java.lang.Object

io.smallrye.reactive.messaging.mqtt.MqttSource

public class MqttSource
extends Object

Constructor Summary

Constructors

Constructor and Description
MqttSource(io.vertx.mutiny.core.Vertx vertx, MqttConnectorIncomingConfiguration config)

Method Summary

Modifier and Type	Method and Description
boolean	isReady()

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttSource

public MqttSource(io.vertx.mutiny.core.Vertx vertx,
                  MqttConnectorIncomingConfiguration config)

Method Detail

isReady

public boolean isReady()