Skip navigation links
Vert.x MQTT 3.8.1.redhat-00005
A C D E F G H I K L M P Q R S T U W 

A

accept() - Method in interface io.vertx.mqtt.MqttEndpoint
Like MqttEndpoint.accept(boolean) with no session is present.
accept(boolean) - Method in interface io.vertx.mqtt.MqttEndpoint
Sends the CONNACK message to the remote MQTT client with "connection accepted" return code.
actualPort() - Method in interface io.vertx.mqtt.MqttServer
The actual port the server is listening on.
addCrlPath(String) - Method in class io.vertx.mqtt.MqttClientOptions
 
addCrlPath(String) - Method in class io.vertx.mqtt.MqttServerOptions
 
addCrlValue(Buffer) - Method in class io.vertx.mqtt.MqttClientOptions
 
addCrlValue(Buffer) - Method in class io.vertx.mqtt.MqttServerOptions
 
addEnabledCipherSuite(String) - Method in class io.vertx.mqtt.MqttClientOptions
 
addEnabledCipherSuite(String) - Method in class io.vertx.mqtt.MqttServerOptions
 
addEnabledSecureTransportProtocol(String) - Method in class io.vertx.mqtt.MqttClientOptions
 
addEnabledSecureTransportProtocol(String) - Method in class io.vertx.mqtt.MqttServerOptions
 
auth() - Method in interface io.vertx.mqtt.MqttEndpoint
 
autoKeepAlive(boolean) - Method in interface io.vertx.mqtt.MqttEndpoint
Enable/disable auto keep alive (sending ping response)

C

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, String, Handler<AsyncResult<MqttConnAckMessage>>) - Method in interface io.vertx.mqtt.MqttClient
Connects to an MQTT server calling connectHandler after connection
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

D

DEFAULT_CLEAN_SESSION - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_HOST - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_KEEP_ALIVE_TIME_SECONDS - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_MAX_INFLIGHT_QUEUE - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_MAX_MESSAGE_SIZE - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_MAX_MESSAGE_SIZE - Static variable in class io.vertx.mqtt.MqttServerOptions
 
DEFAULT_PORT - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_PORT - Static variable in class io.vertx.mqtt.MqttServerOptions
 
DEFAULT_TIMEOUT_ON_CONNECT - Static variable in class io.vertx.mqtt.MqttServerOptions
 
DEFAULT_TLS_PORT - Static variable in class io.vertx.mqtt.MqttServerOptions
 
DEFAULT_TSL_PORT - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_WILL_FLAG - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_WILL_QOS - Static variable in class io.vertx.mqtt.MqttClientOptions
 
DEFAULT_WILL_RETAIN - Static variable in class io.vertx.mqtt.MqttClientOptions
 
disconnect() - Method in interface io.vertx.mqtt.MqttClient
Disconnects from the MQTT server
disconnect(Handler<AsyncResult<Void>>) - Method in interface io.vertx.mqtt.MqttClient
Disconnects from the MQTT server calling disconnectHandler after disconnection
disconnectHandler(Handler<Void>) - Method in interface io.vertx.mqtt.MqttEndpoint
Set a disconnect handler on the MQTT endpoint.

E

endpointHandler(Handler<MqttEndpoint>) - Method in interface io.vertx.mqtt.MqttServer
Set the endpoint handler for the server.
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.mqtt.MqttClient
Set an exception handler for the client, that will be called when an error happens in internal netty structures.
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.mqtt.MqttEndpoint
Set an exception handler.
exceptionHandler(Handler<Throwable>) - Method in interface io.vertx.mqtt.MqttServer
Set an exception handler for the server, that will be called when an error happens independantly of an accepted MqttEndpoint, like a rejected connection

F

fromJson(Iterable<Map.Entry<String, Object>>, MqttClientOptions) - Static method in class io.vertx.mqtt.MqttClientOptionsConverter
 

G

getClientId() - Method in class io.vertx.mqtt.MqttClientOptions
 
getKeepAliveTimeSeconds() - Method in class io.vertx.mqtt.MqttClientOptions
 
getMaxInflightQueue() - Method in class io.vertx.mqtt.MqttClientOptions
 
getMaxMessageSize() - Method in class io.vertx.mqtt.MqttClientOptions
 
getMaxMessageSize() - Method in class io.vertx.mqtt.MqttServerOptions
 
getPassword() - Method in class io.vertx.mqtt.MqttAuth
 
getPassword() - Method in class io.vertx.mqtt.MqttClientOptions
 
getUsername() - Method in class io.vertx.mqtt.MqttAuth
 
getUsername() - Method in class io.vertx.mqtt.MqttClientOptions
 
getWillMessage() - Method in class io.vertx.mqtt.MqttClientOptions
 
getWillMessage() - Method in class io.vertx.mqtt.MqttWill
Deprecated.
getWillMessageBytes() - Method in class io.vertx.mqtt.MqttWill
 
getWillQoS() - Method in class io.vertx.mqtt.MqttClientOptions
 
getWillQos() - Method in class io.vertx.mqtt.MqttWill
 
getWillTopic() - Method in class io.vertx.mqtt.MqttClientOptions
 
getWillTopic() - Method in class io.vertx.mqtt.MqttWill
 
grantedQoSLevels() - Method in interface io.vertx.mqtt.messages.MqttSubAckMessage
 

H

hasPassword() - Method in class io.vertx.mqtt.MqttClientOptions
 
hasUsername() - Method in class io.vertx.mqtt.MqttClientOptions
 

I

io.vertx.mqtt - package io.vertx.mqtt
 
io.vertx.mqtt.messages - package io.vertx.mqtt.messages
 
isAutoClientId() - Method in class io.vertx.mqtt.MqttServerOptions
 
isAutoGeneratedClientId() - Method in class io.vertx.mqtt.MqttClientOptions
 
isAutoKeepAlive() - Method in class io.vertx.mqtt.MqttClientOptions
 
isAutoKeepAlive() - Method in interface io.vertx.mqtt.MqttEndpoint
 
isCleanSession() - Method in class io.vertx.mqtt.MqttClientOptions
 
isCleanSession() - Method in interface io.vertx.mqtt.MqttEndpoint
 
isConnected() - Method in interface io.vertx.mqtt.MqttClient
 
isConnected() - Method in interface io.vertx.mqtt.MqttEndpoint
 
isDup() - Method in interface io.vertx.mqtt.messages.MqttPublishMessage
 
isPublishAutoAck() - Method in interface io.vertx.mqtt.MqttEndpoint
 
isRetain() - Method in interface io.vertx.mqtt.messages.MqttPublishMessage
 
isSessionPresent() - Method in interface io.vertx.mqtt.messages.MqttConnAckMessage
 
isSsl() - Method in interface io.vertx.mqtt.MqttEndpoint
 
isSubscriptionAutoAck() - Method in interface io.vertx.mqtt.MqttEndpoint
 
isWillFlag() - Method in class io.vertx.mqtt.MqttClientOptions
 
isWillFlag() - Method in class io.vertx.mqtt.MqttWill
 
isWillRetain() - Method in class io.vertx.mqtt.MqttClientOptions
 
isWillRetain() - Method in class io.vertx.mqtt.MqttWill
 

K

keepAliveTimeSeconds() - Method in interface io.vertx.mqtt.MqttEndpoint
 

L

lastMessageId() - Method in interface io.vertx.mqtt.MqttEndpoint
 
listen() - Method in interface io.vertx.mqtt.MqttServer
Start the server listening for incoming connections using the specified options through the constructor
listen(int, String) - Method in interface io.vertx.mqtt.MqttServer
Start the server listening for incoming connections on the port and host specified
listen(int, String, Handler<AsyncResult<MqttServer>>) - Method in interface io.vertx.mqtt.MqttServer
Start the server listening for incoming connections on the port and host specified It ignores any options specified through the constructor
listen(int) - Method in interface io.vertx.mqtt.MqttServer
Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.
listen(int, Handler<AsyncResult<MqttServer>>) - Method in interface io.vertx.mqtt.MqttServer
Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.
listen(Handler<AsyncResult<MqttServer>>) - Method in interface io.vertx.mqtt.MqttServer
Start the server listening for incoming connections using the specified options through the constructor
localAddress() - Method in interface io.vertx.mqtt.MqttEndpoint
 

M

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
 
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
Converter for MqttClientOptions.
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, byte[], int, boolean) - Constructor for class io.vertx.mqtt.MqttWill
Constructor
MqttWill(JsonObject) - Constructor for class io.vertx.mqtt.MqttWill
Create instance from JSON

P

password() - Method in class io.vertx.mqtt.MqttAuth
Deprecated.
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, 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
publishCompletionHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttClient
Sets handler which will be called each time publish is completed
publishCompletionHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttEndpoint
Set the pubcomp handler on the MQTT endpoint.
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.

Q

qosLevel() - Method in interface io.vertx.mqtt.messages.MqttPublishMessage
 
qualityOfService() - Method in interface io.vertx.mqtt.MqttTopicSubscription
 

R

reject(MqttConnectReturnCode) - Method in interface io.vertx.mqtt.MqttEndpoint
Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code.
remoteAddress() - Method in interface io.vertx.mqtt.MqttEndpoint
 

S

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.
setKeepAliveTimeSeconds(int) - Method in class io.vertx.mqtt.MqttClientOptions
Set the keep alive timeout 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
 
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
 
setUsername(String) - Method in class io.vertx.mqtt.MqttClientOptions
Set the username
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

T

timeoutOnConnect() - Method in class io.vertx.mqtt.MqttServerOptions
 
toJson() - Method in class io.vertx.mqtt.MqttAuth
Convert instance in JSON
toJson(MqttClientOptions, JsonObject) - Static method in class io.vertx.mqtt.MqttClientOptionsConverter
 
toJson(MqttClientOptions, Map<String, Object>) - Static method in class io.vertx.mqtt.MqttClientOptionsConverter
 
toJson() - Method in class io.vertx.mqtt.MqttWill
Convert instance in JSON
topicName() - Method in interface io.vertx.mqtt.messages.MqttPublishMessage
 
topicName() - Method in interface io.vertx.mqtt.MqttTopicSubscription
 
topics() - Method in interface io.vertx.mqtt.messages.MqttUnsubscribeMessage
 
topicSubscriptions() - Method in interface io.vertx.mqtt.messages.MqttSubscribeMessage
 
toString() - Method in class io.vertx.mqtt.MqttClientOptions
 

U

unsubscribe(String) - Method in interface io.vertx.mqtt.MqttClient
Unsubscribe from receiving messages on given topic
unsubscribe(String, Handler<AsyncResult<Integer>>) - Method in interface io.vertx.mqtt.MqttClient
Unsubscribe from receiving messages on given topic
unsubscribeAcknowledge(int) - Method in interface io.vertx.mqtt.MqttEndpoint
Sends the UNSUBACK message to the remote MQTT client
unsubscribeCompletionHandler(Handler<Integer>) - Method in interface io.vertx.mqtt.MqttClient
Sets handler which will be called after UNSUBACK packet receiving
unsubscribeHandler(Handler<MqttUnsubscribeMessage>) - Method in interface io.vertx.mqtt.MqttEndpoint
Set a unsubscribe handler on the MQTT endpoint.
userName() - Method in class io.vertx.mqtt.MqttAuth
Deprecated.
use instead MqttAuth.getUsername() ()}

W

will() - Method in interface io.vertx.mqtt.MqttEndpoint
 
willMessage() - Method in class io.vertx.mqtt.MqttWill
Deprecated.
willQos() - Method in class io.vertx.mqtt.MqttWill
Deprecated.
use MqttWill.willQos() instead
willTopic() - Method in class io.vertx.mqtt.MqttWill
Deprecated.
A C D E F G H I K L M P Q R S T U W 
Skip navigation links
Vert.x MQTT 3.8.1.redhat-00005

Copyright © 2019 Eclipse. All rights reserved.