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

Packages that use MqttClient

Package	Description
io.vertx.mutiny.mqtt

Uses of MqttClient in io.vertx.mutiny.mqtt

Fields in io.vertx.mutiny.mqtt with type parameters of type MqttClient

Modifier and Type	Field	Description
static final TypeArg<MqttClient>	MqttClient.__TYPE_ARG

Methods in io.vertx.mutiny.mqtt that return MqttClient

Modifier and Type	Method	Description
MqttClient	MqttClient.authenticationExchangeAndForget(io.vertx.mqtt.messages.codes.MqttAuthenticateReasonCode reasonCode, io.netty.handler.codec.mqtt.MqttProperties properties)	Send an AUTH packet to the server.
MqttClient	MqttClient.authenticationExchangeHandler(Consumer<MqttAuthenticationExchangeMessage> handler)	Sets a handler that will be called when the server sends an AUTH packet (MQTT 5.0 Enhanced Authentication, see §3.15).
MqttClient	MqttClient.closeHandler(Runnable closeHandler)	Set a handler that will be called when the connection with server is closed
MqttClient	MqttClient.connectAndForget(int port, String host)	Connects to an MQTT server calling connectHandler after connection
MqttClient	MqttClient.connectAndForget(int port, String host, String serverName)	Connects to an MQTT server calling connectHandler after connection
MqttClient	MqttClient.connectAndForget(int port, String host, String serverName, Map<String,String> userProperties)	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, io.vertx.mqtt.MqttClientOptions options)	Return an MQTT client instance
MqttClient	MqttClient.disconnectAndForget()	Disconnects from the MQTT server
MqttClient	MqttClient.disconnectMessageHandler(Consumer<MqttDisconnectMessage> handler)	Sets a handler that will be called when the server sends a DISCONNECT packet.
MqttClient	MqttClient.exceptionHandler(Consumer<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 delegate)	Creates a new instance of the MqttClient.
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(Runnable pingResponseHandler)	Sets handler which will be called after PINGRESP packet receiving
MqttClient	MqttClient.publishAckMessageHandler(Consumer<MqttPubAckMessage> handler)	Sets a handler which will be called each time a PUBACK is received from the server.
MqttClient	MqttClient.publishAndForget(int id, String topic, io.vertx.core.buffer.Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain)	Sends the PUBLISH message to the remote MQTT server with a specific message ID
MqttClient	MqttClient.publishAndForget(String topic, io.vertx.core.buffer.Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain)	Sends the PUBLISH message to the remote MQTT server
MqttClient	MqttClient.publishCompletionExpirationHandler(Consumer<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(Consumer<Integer> publishCompletionHandler)	Sets a handler which will be called each time the publishing of a message has been completed.
MqttClient	MqttClient.publishCompletionUnknownPacketIdHandler(Consumer<Integer> publishCompletionPhantomHandler)	Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown packet ID.
MqttClient	MqttClient.publishCompMessageHandler(Consumer<MqttPubCompMessage> handler)	Sets a handler which will be called each time a PUBCOMP is received from the server.
MqttClient	MqttClient.publishHandler(Consumer<MqttPublishMessage> publishHandler)	Sets handler which will be called each time server publish something to client
MqttClient	MqttClient.publishRecMessageHandler(Consumer<MqttPubRecMessage> handler)	Sets a handler which will be called each time a PUBREC is received from the server.
MqttClient	MqttClient.publishReleaseAndForget(int publishMessageId)	Sends the PUBREL message to the remote MQTT server.
MqttClient	MqttClient.subscribeAndForget(String topic, int qos)	Subscribes to the topic with a specified QoS level
MqttClient	MqttClient.subscribeAndForget(Map<String,Integer> topics)	Subscribes to the topics with related QoS levels
MqttClient	MqttClient.subscribeCompletionHandler(Consumer<MqttSubAckMessage> subscribeCompletionHandler)	Sets handler which will be called after SUBACK packet receiving
MqttClient	MqttClient.unsubscribeAndForget(String topic)	Unsubscribe from receiving messages on given topic
MqttClient	MqttClient.unsubscribeAndForget(List<String> topics)	Unsubscribe from receiving messages on given list of topic
MqttClient	MqttClient.unsubscribeCompletionHandler(Consumer<Integer> unsubscribeCompletionHandler)	Sets handler which will be called after UNSUBACK packet receiving
MqttClient	MqttClient.unsubscribeCompletionMessageHandler(Consumer<MqttUnsubAckMessage> unsubscribeCompletionMessageHandler)	Sets handler which will be called after UNSUBACK packet receiving