Package | Description |
---|---|
io.vertx.rxjava3.mqtt |
Modifier and Type | Field and Description |
---|---|
static TypeArg<MqttClient> |
MqttClient.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
MqttClient |
MqttClient.closeHandler(io.vertx.core.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,
io.vertx.mqtt.MqttClientOptions options)
Return an MQTT client instance
|
MqttClient |
MqttClient.exceptionHandler(io.vertx.core.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(io.vertx.mqtt.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(io.vertx.core.Handler<Void> pingResponseHandler)
Sets handler which will be called after PINGRESP packet receiving
|
MqttClient |
MqttClient.publishCompletionExpirationHandler(io.vertx.core.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(io.vertx.core.Handler<Integer> publishCompletionHandler)
Sets a handler which will be called each time the publishing of a message has been completed.
|
MqttClient |
MqttClient.publishCompletionUnknownPacketIdHandler(io.vertx.core.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(io.vertx.core.Handler<MqttPublishMessage> publishHandler)
Sets handler which will be called each time server publish something to client
|
MqttClient |
MqttClient.subscribeCompletionHandler(io.vertx.core.Handler<MqttSubAckMessage> subscribeCompletionHandler)
Sets handler which will be called after SUBACK packet receiving
|
MqttClient |
MqttClient.unsubscribeCompletionHandler(io.vertx.core.Handler<Integer> unsubscribeCompletionHandler)
Sets handler which will be called after UNSUBACK packet receiving
|
Copyright © 2022 Eclipse. All rights reserved.