## Uses of Class
io.vertx.reactivex.mqtt.MqttClient

- Packages that use MqttClient
  Package | Description
  --- | ---
  io.vertx.reactivex.mqtt |

- - ### Uses of MqttClient in io.vertx.reactivex.mqtt

    Fields in io.vertx.reactivex.mqtt with type parameters of type MqttClient
    Modifier and Type | Field and Description
    --- | ---
    `static io.vertx.lang.rx.TypeArg<MqttClient>` | MqttClient.`__TYPE_ARG`

    Methods in io.vertx.reactivex.mqtt that return MqttClient
    Modifier and Type | Method and Description
    --- | ---
    `MqttClient` | MqttClient.`closeHandler(Handler<Void> closeHandler)` Set a handler that will be called when the connection with server is closed
    `MqttClient` | MqttClient.`connect(int port, String host)` Connects to an MQTT server calling connectHandler after connection
    `MqttClient` | MqttClient.`connect(int port, String host, Handler<AsyncResult<MqttConnAckMessage>> connectHandler)` Connects to an MQTT server calling connectHandler after connection
    `MqttClient` | MqttClient.`connect(int port, String host, String serverName)` Connects to an MQTT server calling connectHandler after connection
    `MqttClient` | MqttClient.`connect(int port, String host, String serverName, Handler<AsyncResult<MqttConnAckMessage>> connectHandler)` Connects to an MQTT server calling connectHandler after connection
    `static MqttClient` | MqttClient.`create(Vertx vertx)` Return an MQTT client instance using the default options
    `static MqttClient` | MqttClient.`create(Vertx vertx, MqttClientOptions options)` Return an MQTT client instance
    `MqttClient` | MqttClient.`disconnect()` Disconnects from the MQTT server calling disconnectHandler after disconnection
    `MqttClient` | MqttClient.`disconnect(Handler<AsyncResult<Void>> disconnectHandler)` Disconnects from the MQTT server calling disconnectHandler after disconnection
    `MqttClient` | MqttClient.`exceptionHandler(Handler<Throwable> handler)` Set an exception handler for the client, that will be called when an error happens in internal netty structures.
    `static MqttClient` | MqttClient.`newInstance(MqttClient arg)`
    `MqttClient` | MqttClient.`ping()` This method is needed by the client in order to avoid server closes the connection due to the keep alive timeout if client has no messages to send
    `MqttClient` | MqttClient.`pingResponseHandler(Handler<Void> pingResponseHandler)` Sets handler which will be called after PINGRESP packet receiving
    `MqttClient` | MqttClient.`publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain)` Sends the PUBLISH message to the remote MQTT server
    `MqttClient` | MqttClient.`publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, Handler<AsyncResult<Integer>> publishSentHandler)` Sends the PUBLISH message to the remote MQTT server
    `MqttClient` | MqttClient.`publishCompletionExpirationHandler(Handler<Integer> publishCompletionExpirationHandler)` Sets a handler which will be called when the client does not receive a PUBACK or PUBREC/PUBCOMP for a message published using QoS 1 or 2 respectively.
    `MqttClient` | MqttClient.`publishCompletionHandler(Handler<Integer> publishCompletionHandler)` Sets a handler which will be called each time the publishing of a message has been completed.
    `MqttClient` | MqttClient.`publishCompletionUnknownPacketIdHandler(Handler<Integer> publishCompletionPhantomHandler)` Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown packet ID.
    `MqttClient` | MqttClient.`publishHandler(Handler<MqttPublishMessage> publishHandler)` Sets handler which will be called each time server publish something to client
    `MqttClient` | MqttClient.`subscribe(Map<String,Integer> topics)` Subscribes to the topic and adds a handler which will be called after the request is sent
    `MqttClient` | MqttClient.`subscribe(Map<String,Integer> topics, Handler<AsyncResult<Integer>> subscribeSentHandler)` Subscribes to the topic and adds a handler which will be called after the request is sent
    `MqttClient` | MqttClient.`subscribe(String topic, int qos)` Subscribes to the topic with a specified QoS level
    `MqttClient` | MqttClient.`subscribe(String topic, int qos, Handler<AsyncResult<Integer>> subscribeSentHandler)` Subscribes to the topic with a specified QoS level
    `MqttClient` | MqttClient.`subscribeCompletionHandler(Handler<MqttSubAckMessage> subscribeCompletionHandler)` Sets handler which will be called after SUBACK packet receiving
    `MqttClient` | MqttClient.`unsubscribe(String topic)` Unsubscribe from receiving messages on given topic
    `MqttClient` | MqttClient.`unsubscribe(String topic, Handler<AsyncResult<Integer>> unsubscribeSentHandler)` Unsubscribe from receiving messages on given topic
    `MqttClient` | MqttClient.`unsubscribeCompletionHandler(Handler<Integer> unsubscribeCompletionHandler)` Sets handler which will be called after UNSUBACK packet receiving

Copyright © 2022 Eclipse. All rights reserved.