Package | Description |
---|---|
io.smallrye.reactive.messaging.mqtt.session | |
io.smallrye.reactive.messaging.mqtt.session.impl |
Modifier and Type | Method and Description |
---|---|
MqttClientSessionOptions |
MqttClientSessionOptions.setHostname(String hostname) |
MqttClientSessionOptions |
MqttClientSessionOptions.setPort(int port) |
MqttClientSessionOptions |
MqttClientSessionOptions.setReconnectDelay(ReconnectDelayOptions reconnectDelay) |
MqttClientSessionOptions |
MqttClientSessionOptions.setServerName(Optional<String> serverName) |
Modifier and Type | Method and Description |
---|---|
static MqttClientSession |
MqttClientSession.create(io.vertx.core.Vertx vertx,
MqttClientSessionOptions options)
Create a new MQTT client session.
|
Constructor and Description |
---|
MqttClientSessionOptions(MqttClientSessionOptions other)
Copy constructor
|
Constructor and Description |
---|
MqttClientSessionImpl(io.vertx.core.Vertx vertx,
MqttClientSessionOptions options)
Create a new instance, which is not started.
|
Copyright © 2018–2021 SmallRye. All rights reserved.