MqttClient |
MqttClient.authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> authenticationExchangeHandler) |
Sets handler which will be called after AUTH packet receiving
|
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.
|
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
|