Package io.smallrye.reactive.messaging.mqtt

Class Clients.ClientHolder

java.lang.Object

io.smallrye.reactive.messaging.mqtt.Clients.ClientHolder

Enclosing class:

Clients

public static class Clients.ClientHolder
extends Object

Constructor Summary

Constructors

Constructor	Description
ClientHolder(io.vertx.mutiny.mqtt.MqttClient client, String host, int port, String server)

Method Summary

Modifier and Type	Method	Description
void	close()
io.smallrye.mutiny.Uni<io.vertx.mutiny.mqtt.MqttClient>	connect()
io.smallrye.mutiny.Multi<io.vertx.mutiny.mqtt.messages.MqttPublishMessage>	stream()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientHolder

public ClientHolder(io.vertx.mutiny.mqtt.MqttClient client,
                    String host,
                    int port,
                    String server)

Method Detail

connect

public io.smallrye.mutiny.Uni<io.vertx.mutiny.mqtt.MqttClient> connect()

close

public void close()

stream

public io.smallrye.mutiny.Multi<io.vertx.mutiny.mqtt.messages.MqttPublishMessage> stream()