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

Packages that use MqttClient

Package	Description
io.vertx.rxjava.mqtt

Uses of MqttClient in io.vertx.rxjava.mqtt

Fields in io.vertx.rxjava.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.rxjava.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, Handler<AsyncResult<MqttConnAckMessage>> connectHandler) 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
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 topics with related QoS levels
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