Package | Description |
---|---|
io.vertx.mqtt | |
io.vertx.reactivex.mqtt | |
io.vertx.rxjava.mqtt | |
io.vertx.rxjava3.mqtt |
Modifier and Type | Method and Description |
---|---|
MqttClientOptions |
MqttClientOptions.addCrlPath(String crlPath) |
MqttClientOptions |
MqttClientOptions.addCrlValue(Buffer crlValue) |
MqttClientOptions |
MqttClientOptions.addEnabledCipherSuite(String suite) |
MqttClientOptions |
MqttClientOptions.addEnabledSecureTransportProtocol(String protocol) |
MqttClientOptions |
MqttClientOptions.setAckTimeout(int ackTimeoutSeconds)
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.
|
MqttClientOptions |
MqttClientOptions.setAutoGeneratedClientId(boolean isAutoGeneratedClientId)
Set if the MQTT client must generate clientId automatically
(default is true)
|
MqttClientOptions |
MqttClientOptions.setAutoKeepAlive(boolean isAutoKeepAlive)
Set if the MQTT client must handle PINGREQ automatically
(default is true)
|
MqttClientOptions |
MqttClientOptions.setCleanSession(boolean cleanSession)
Set to start with a clean session (or not)
|
MqttClientOptions |
MqttClientOptions.setClientId(String clientId)
Set the client identifier
|
MqttClientOptions |
MqttClientOptions.setIdleTimeout(int idleTimeout)
Deprecated.
|
MqttClientOptions |
MqttClientOptions.setKeepAliveInterval(int keepAliveInterval)
Set the keep alive interval in seconds
|
MqttClientOptions |
MqttClientOptions.setKeyCertOptions(KeyCertOptions options) |
MqttClientOptions |
MqttClientOptions.setKeyStoreOptions(JksOptions options) |
MqttClientOptions |
MqttClientOptions.setMaxInflightQueue(int maxInflightQueue)
Set max count of unacknowledged messages
|
MqttClientOptions |
MqttClientOptions.setMaxMessageSize(int maxMessageSize)
Set max MQTT message size
|
MqttClientOptions |
MqttClientOptions.setPassword(String password)
Set the password
|
MqttClientOptions |
MqttClientOptions.setPemKeyCertOptions(PemKeyCertOptions options) |
MqttClientOptions |
MqttClientOptions.setPemTrustOptions(PemTrustOptions options) |
MqttClientOptions |
MqttClientOptions.setPfxKeyCertOptions(PfxOptions options) |
MqttClientOptions |
MqttClientOptions.setPfxTrustOptions(PfxOptions options) |
MqttClientOptions |
MqttClientOptions.setReceiveBufferSize(int receiveBufferSize) |
MqttClientOptions |
MqttClientOptions.setSsl(boolean ssl) |
MqttClientOptions |
MqttClientOptions.setTrustAll(boolean trustAll) |
MqttClientOptions |
MqttClientOptions.setTrustOptions(TrustOptions options) |
MqttClientOptions |
MqttClientOptions.setTrustStoreOptions(JksOptions options) |
MqttClientOptions |
MqttClientOptions.setUsername(String username)
Set the username
|
MqttClientOptions |
MqttClientOptions.setWillFlag(boolean willFlag)
Set if will information are provided on connection
|
MqttClientOptions |
MqttClientOptions.setWillMessage(String willMessage)
Set the content of the will message
|
MqttClientOptions |
MqttClientOptions.setWillQoS(int willQoS)
Set the QoS level for the will message
|
MqttClientOptions |
MqttClientOptions.setWillRetain(boolean willRetain)
Set if the will message must be retained
|
MqttClientOptions |
MqttClientOptions.setWillTopic(String willTopic)
Set the topic on which the will message will be published
|
Modifier and Type | Method and Description |
---|---|
static MqttClient |
MqttClient.create(Vertx vertx,
MqttClientOptions options)
Return an MQTT client instance
|
static void |
MqttClientOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
MqttClientOptions obj) |
static void |
MqttClientOptionsConverter.toJson(MqttClientOptions obj,
JsonObject json) |
static void |
MqttClientOptionsConverter.toJson(MqttClientOptions obj,
Map<String,Object> json) |
Constructor and Description |
---|
MqttClientOptions(MqttClientOptions other)
Copy constructor
|
Modifier and Type | Method and Description |
---|---|
static MqttClient |
MqttClient.create(Vertx vertx,
MqttClientOptions options)
Return an MQTT client instance
|
Modifier and Type | Method and Description |
---|---|
static MqttClient |
MqttClient.create(Vertx vertx,
MqttClientOptions options)
Return an MQTT client instance
|
Modifier and Type | Method and Description |
---|---|
static MqttClient |
MqttClient.create(Vertx vertx,
MqttClientOptions options)
Return an MQTT client instance
|
Copyright © 2021 Eclipse. All rights reserved.