Class Clients.ClientHolder

  • Enclosing class:
    Clients

    public static class Clients.ClientHolder
    extends Object
    • 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()
      • stream

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