- clientId() - Method in interface io.vertx.mqtt.MqttClient
-
- clientIdentifier() - Method in interface io.vertx.mqtt.MqttEndpoint
-
- close() - Method in interface io.vertx.mqtt.MqttEndpoint
-
Close the endpoint, so the connection with remote MQTT client
- close() - Method in interface io.vertx.mqtt.MqttServer
-
Close the server.
- close(Handler<AsyncResult<Void>>) - Method in interface io.vertx.mqtt.MqttServer
-
Close the server supplying an handler that will be called when the server is actually closed (or has failed).
- closeHandler(Handler<Void>) - Method in interface io.vertx.mqtt.MqttClient
-
Set a handler that will be called when the connection with server is closed
- closeHandler(Handler<Void>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set a close handler.
- code() - Method in interface io.vertx.mqtt.messages.MqttConnAckMessage
-
- code() - Method in class io.vertx.mqtt.MqttConnectionException
-
- code() - Method in class io.vertx.mqtt.MqttException
-
- connect(int, String, Handler<AsyncResult<MqttConnAckMessage>>) - Method in interface io.vertx.mqtt.MqttClient
-
Connects to an MQTT server calling connectHandler after connection
- connect(int, String) - Method in interface io.vertx.mqtt.MqttClient
-
- connect(int, String, String, Handler<AsyncResult<MqttConnAckMessage>>) - Method in interface io.vertx.mqtt.MqttClient
-
Connects to an MQTT server calling connectHandler after connection
- connect(int, String, String) - Method in interface io.vertx.mqtt.MqttClient
-
- create(MqttConnectReturnCode, boolean) - Static method in interface io.vertx.mqtt.messages.MqttConnAckMessage
-
Create a concrete instance of a Vert.x connack message
- create(int, MqttQoS, boolean, boolean, String, ByteBuf) - Static method in interface io.vertx.mqtt.messages.MqttPublishMessage
-
Create a concrete instance of a Vert.x publish message
- create(int, List<Integer>) - Static method in interface io.vertx.mqtt.messages.MqttSubAckMessage
-
Create a concrete instance of a Vert.x suback message
- create(int, List<MqttTopicSubscription>) - Static method in interface io.vertx.mqtt.messages.MqttSubscribeMessage
-
Create a concrete instance of a Vert.x subscribe message
- create(int, List<String>) - Static method in interface io.vertx.mqtt.messages.MqttUnsubscribeMessage
-
Create a concrete instance of a Vert.x unsubscribe message
- create(Vertx, MqttClientOptions) - Static method in interface io.vertx.mqtt.MqttClient
-
Return an MQTT client instance
- create(Vertx) - Static method in interface io.vertx.mqtt.MqttClient
-
Return an MQTT client instance using the default options
- create(Vertx, MqttServerOptions) - Static method in interface io.vertx.mqtt.MqttServer
-
Return an MQTT server instance
- create(Vertx) - Static method in interface io.vertx.mqtt.MqttServer
-
Return an MQTT server instance using default options
- messageId() - Method in interface io.vertx.mqtt.messages.MqttMessage
-
- MQTT_INFLIGHT_QUEUE_FULL - Static variable in class io.vertx.mqtt.MqttException
-
- MQTT_INVALID_TOPIC_FILTER - Static variable in class io.vertx.mqtt.MqttException
-
- MQTT_INVALID_TOPIC_NAME - Static variable in class io.vertx.mqtt.MqttException
-
- MQTT_SUBPROTOCOL_CSV_LIST - Static variable in class io.vertx.mqtt.MqttServerOptions
-
- MqttAuth - Class in io.vertx.mqtt
-
MQTT authentication information
- MqttAuth(String, String) - Constructor for class io.vertx.mqtt.MqttAuth
-
Constructor
- MqttAuth(JsonObject) - Constructor for class io.vertx.mqtt.MqttAuth
-
Create instance from JSON
- MqttClient - Interface in io.vertx.mqtt
-
An MQTT client
- MqttClientOptions - Class in io.vertx.mqtt
-
Represents options used by the MQTT client.
- MqttClientOptions() - Constructor for class io.vertx.mqtt.MqttClientOptions
-
Default constructor
- MqttClientOptions(JsonObject) - Constructor for class io.vertx.mqtt.MqttClientOptions
-
Create an instance of MqttClientOptions from JSON
- MqttClientOptions(MqttClientOptions) - Constructor for class io.vertx.mqtt.MqttClientOptions
-
Copy constructor
- MqttClientOptionsConverter - Class in io.vertx.mqtt
-
- MqttClientOptionsConverter() - Constructor for class io.vertx.mqtt.MqttClientOptionsConverter
-
- MqttConnAckMessage - Interface in io.vertx.mqtt.messages
-
Represents an MQTT CONNACK message
- MqttConnectionException - Class in io.vertx.mqtt
-
Exception raised when a connection request fails at MQTT level
- MqttConnectionException(MqttConnectReturnCode) - Constructor for class io.vertx.mqtt.MqttConnectionException
-
Constructor
- MqttEndpoint - Interface in io.vertx.mqtt
-
Represents an MQTT endpoint for point-to-point communication with the remote MQTT client
- MqttException - Class in io.vertx.mqtt
-
Exception raised with a specific reason code
- MqttException(int) - Constructor for class io.vertx.mqtt.MqttException
-
Constructor
- MqttException(int, String) - Constructor for class io.vertx.mqtt.MqttException
-
Constructor
- MqttMessage - Interface in io.vertx.mqtt.messages
-
Represent the interface for each MQTT message
- MqttPublishMessage - Interface in io.vertx.mqtt.messages
-
Represents an MQTT PUBLISH message
- MqttServer - Interface in io.vertx.mqtt
-
An MQTT server
- MqttServerOptions - Class in io.vertx.mqtt
-
Represents options used by the MQTT server
- MqttServerOptions() - Constructor for class io.vertx.mqtt.MqttServerOptions
-
Default constructor
- MqttServerOptions(JsonObject) - Constructor for class io.vertx.mqtt.MqttServerOptions
-
Create an options from JSON
- MqttServerOptions(MqttServerOptions) - Constructor for class io.vertx.mqtt.MqttServerOptions
-
Copy constructor
- MqttSubAckMessage - Interface in io.vertx.mqtt.messages
-
Represents an MQTT SUBACK message
- MqttSubscribeMessage - Interface in io.vertx.mqtt.messages
-
Represents an MQTT SUBSCRIBE message
- MqttTopicSubscription - Interface in io.vertx.mqtt
-
Represents a subscription to a topic
- MqttUnsubscribeMessage - Interface in io.vertx.mqtt.messages
-
Represents an MQTT UNSUBSCRIBE message
- MqttWill - Class in io.vertx.mqtt
-
Will information from the remote MQTT client
- MqttWill(boolean, String, Buffer, int, boolean) - Constructor for class io.vertx.mqtt.MqttWill
-
Constructor
- MqttWill(JsonObject) - Constructor for class io.vertx.mqtt.MqttWill
-
Create instance from JSON
- payload() - Method in interface io.vertx.mqtt.messages.MqttPublishMessage
-
- ping() - Method in interface io.vertx.mqtt.MqttClient
-
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
- pingHandler(Handler<Void>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set the pingreq handler on the MQTT endpoint.
- pingResponseHandler(Handler<Void>) - Method in interface io.vertx.mqtt.MqttClient
-
Sets handler which will be called after PINGRESP packet receiving
- pong() - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PINGRESP message to the remote MQTT client
- protocolName() - Method in interface io.vertx.mqtt.MqttEndpoint
-
- protocolVersion() - Method in interface io.vertx.mqtt.MqttEndpoint
-
- publish(String, Buffer, MqttQoS, boolean, boolean) - Method in interface io.vertx.mqtt.MqttClient
-
Sends the PUBLISH message to the remote MQTT server
- publish(String, Buffer, MqttQoS, boolean, boolean, Handler<AsyncResult<Integer>>) - Method in interface io.vertx.mqtt.MqttClient
-
Sends the PUBLISH message to the remote MQTT server
- publish(String, Buffer, MqttQoS, boolean, boolean) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBLISH message to the remote MQTT client
- publish(String, Buffer, MqttQoS, boolean, boolean, Handler<AsyncResult<Integer>>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBLISH message to the remote MQTT server
- publish(String, Buffer, MqttQoS, boolean, boolean, int) - Method in interface io.vertx.mqtt.MqttEndpoint
-
- publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler<AsyncResult<Integer>>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
- publishAcknowledge(int) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBACK message to the remote MQTT client
- publishAcknowledgeHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set the puback handler on the MQTT endpoint.
- publishAutoAck(boolean) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Enable/disable publishing (in/out) auto acknowledge
- publishComplete(int) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBCOMP message to the remote MQTT client
- publishCompletionExpirationHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttClient
-
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.
- publishCompletionHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttClient
-
Sets a handler which will be called each time the publishing of a message has been completed.
- publishCompletionHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set the pubcomp handler on the MQTT endpoint.
- publishCompletionUnknownPacketIdHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttClient
-
Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown
packet ID.
- publishHandler(Handler<MqttPublishMessage>) - Method in interface io.vertx.mqtt.MqttClient
-
Sets handler which will be called each time server publish something to client
- publishHandler(Handler<MqttPublishMessage>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set the publish handler on the MQTT endpoint.
- publishReceived(int) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBREC message to the remote MQTT client
- publishReceivedHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set the pubrec handler on the MQTT endpoint.
- publishRelease(int) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the PUBREL message to the remote MQTT client
- publishReleaseHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set the pubrel handler on the MQTT endpoint.
- setAckTimeout(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
Sets the time in seconds after which the client will stop waiting for a PUBACK, PUBREC
or PUBCOMP packet from the server in response to a packet it has sent.
- setAutoClientId(boolean) - Method in class io.vertx.mqtt.MqttServerOptions
-
Set if clientid should be auto-generated when it's "zero-bytes"
- setAutoGeneratedClientId(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set if the MQTT client must generate clientId automatically
(default is true)
- setAutoKeepAlive(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set if the MQTT client must handle PINGREQ automatically
(default is true)
- setCleanSession(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set to start with a clean session (or not)
- setClientAuth(ClientAuth) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setClientId(String) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the client identifier
- setClientIdentifier(String) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set client identifier if not provided by the remote MQTT client (zero-bytes)
- setHost(String) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setIdleTimeout(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
Deprecated.
- setKeepAliveInterval(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the keep alive interval in seconds
- setKeyCertOptions(KeyCertOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setKeyCertOptions(KeyCertOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setKeyStoreOptions(JksOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setKeyStoreOptions(JksOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setMaxInflightQueue(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set max count of unacknowledged messages
- setMaxMessageSize(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set max MQTT message size
- setMaxMessageSize(int) - Method in class io.vertx.mqtt.MqttServerOptions
-
Set max MQTT message size
- setPassword(String) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the password
- setPemKeyCertOptions(PemKeyCertOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setPemKeyCertOptions(PemKeyCertOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setPemTrustOptions(PemTrustOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setPemTrustOptions(PemTrustOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setPfxKeyCertOptions(PfxOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setPfxKeyCertOptions(PfxOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setPfxTrustOptions(PfxOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setPfxTrustOptions(PfxOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setPort(int) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setProxyProtocolTimeout(long) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setProxyProtocolTimeoutUnit(TimeUnit) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setReceiveBufferSize(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setReceiveBufferSize(int) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setSni(boolean) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setSsl(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setSsl(boolean) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setTimeoutOnConnect(int) - Method in class io.vertx.mqtt.MqttServerOptions
-
Set the timeout on CONNECT packet
- setTrustAll(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setTrustOptions(TrustOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setTrustOptions(TrustOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setTrustStoreOptions(JksOptions) - Method in class io.vertx.mqtt.MqttClientOptions
-
- setTrustStoreOptions(JksOptions) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setUseProxyProtocol(boolean) - Method in class io.vertx.mqtt.MqttServerOptions
-
- setUsername(String) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the username
- setUseWebSocket(boolean) - Method in class io.vertx.mqtt.MqttServerOptions
-
enable mqtt over websocket
- setWillFlag(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set if will information are provided on connection
- setWillMessage(String) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the content of the will message
- setWillQoS(int) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the QoS level for the will message
- setWillRetain(boolean) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set if the will message must be retained
- setWillTopic(String) - Method in class io.vertx.mqtt.MqttClientOptions
-
Set the topic on which the will message will be published
- sslSession() - Method in interface io.vertx.mqtt.MqttEndpoint
-
- subscribe(String, int) - Method in interface io.vertx.mqtt.MqttClient
-
Subscribes to the topic with a specified QoS level
- subscribe(String, int, Handler<AsyncResult<Integer>>) - Method in interface io.vertx.mqtt.MqttClient
-
Subscribes to the topic with a specified QoS level
- subscribe(Map<String, Integer>) - Method in interface io.vertx.mqtt.MqttClient
-
Subscribes to the topics with related QoS levels
- subscribe(Map<String, Integer>, Handler<AsyncResult<Integer>>) - Method in interface io.vertx.mqtt.MqttClient
-
Subscribes to the topic and adds a handler which will be called after the request is sent
- subscribeAcknowledge(int, List<MqttQoS>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Sends the SUBACK message to the remote MQTT client
- subscribeCompletionHandler(Handler<MqttSubAckMessage>) - Method in interface io.vertx.mqtt.MqttClient
-
Sets handler which will be called after SUBACK packet receiving
- subscribeHandler(Handler<MqttSubscribeMessage>) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Set a subscribe handler on the MQTT endpoint.
- subscriptionAutoAck(boolean) - Method in interface io.vertx.mqtt.MqttEndpoint
-
Enable/disable subscription/unsubscription requests auto acknowledge