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

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)