Package | Description |
---|---|
io.smallrye.reactive.messaging.mqtt.session | |
io.smallrye.reactive.messaging.mqtt.session.impl |
Modifier and Type | Method and Description |
---|---|
static RequestedQoS |
RequestedQoS.valueOf(Integer qos) |
static RequestedQoS |
RequestedQoS.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static RequestedQoS[] |
RequestedQoS.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
io.vertx.core.Future<Integer> |
MqttClientSession.subscribe(String topic,
RequestedQoS qos)
Subscribes to a single topic with related QoS level.
|
Modifier and Type | Method and Description |
---|---|
io.vertx.core.Future<Integer> |
MqttClientSessionImpl.subscribe(String topic,
RequestedQoS qos) |
Copyright © 2018–2021 SmallRye. All rights reserved.