MqttClient |
MqttClient.closeHandler(Runnable closeHandler) |
|
MqttClient |
MqttClient.connectAndForget(int port,
String host) |
|
MqttClient |
MqttClient.connectAndForget(int port,
String host,
String serverName) |
|
static MqttClient |
MqttClient.create(Vertx vertx) |
|
static MqttClient |
MqttClient.create(Vertx vertx,
io.vertx.mqtt.MqttClientOptions options) |
|
MqttClient |
MqttClient.disconnectAndForget() |
Variant of disconnect() that ignores the result of the operation.
|
MqttClient |
MqttClient.exceptionHandler(Consumer<Throwable> handler) |
|
static MqttClient |
MqttClient.newInstance(io.vertx.mqtt.MqttClient arg) |
|
MqttClient |
MqttClient.ping() |
|
MqttClient |
MqttClient.pingResponseHandler(Runnable pingResponseHandler) |
|
MqttClient |
MqttClient.publishAndForget(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain) |
|
MqttClient |
MqttClient.publishCompletionExpirationHandler(Consumer<Integer> publishCompletionExpirationHandler) |
|
MqttClient |
MqttClient.publishCompletionHandler(Consumer<Integer> publishCompletionHandler) |
|
MqttClient |
MqttClient.publishCompletionUnknownPacketIdHandler(Consumer<Integer> publishCompletionPhantomHandler) |
|
MqttClient |
MqttClient.publishHandler(Consumer<MqttPublishMessage> publishHandler) |
|
MqttClient |
MqttClient.subscribeAndForget(String topic,
int qos) |
|
MqttClient |
MqttClient.subscribeAndForget(Map<String,Integer> topics) |
|
MqttClient |
MqttClient.subscribeCompletionHandler(Consumer<MqttSubAckMessage> subscribeCompletionHandler) |
|
MqttClient |
MqttClient.unsubscribeAndForget(String topic) |
|
MqttClient |
MqttClient.unsubscribeAndForget(List<String> topics) |
|
MqttClient |
MqttClient.unsubscribeCompletionHandler(Consumer<Integer> unsubscribeCompletionHandler) |
|