Package | Description |
---|---|
io.vertx.rxjava3.mqtt |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<MqttClient> |
MqttClient.__TYPE_ARG |
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
|
Copyright © 2023 Eclipse. All rights reserved.