Uses of Class
io.vertx.rxjava3.mqtt.MqttClient

Packages that use MqttClient

Package	Description
io.vertx.rxjava3.mqtt

Uses of MqttClient in io.vertx.rxjava3.mqtt

Fields in io.vertx.rxjava3.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.rxjava3.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
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.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.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.subscribeCompletionHandler(Handler<MqttSubAckMessage> subscribeCompletionHandler) Sets handler which will be called after SUBACK packet receiving
MqttClient	MqttClient.unsubscribeCompletionHandler(Handler<Integer> unsubscribeCompletionHandler) Sets handler which will be called after UNSUBACK packet receiving