Package | Description |
---|---|
org.fusesource.mqtt.client | |
org.fusesource.mqtt.codec |
Modifier and Type | Method and Description |
---|---|
QoS |
MQTT.getWillQos() |
QoS |
Topic.qos() |
static QoS |
QoS.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static QoS[] |
QoS.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockingConnection.publish(String topic,
byte[] payload,
QoS qos,
boolean retain) |
Future<Void> |
FutureConnection.publish(String topic,
byte[] payload,
QoS qos,
boolean retain) |
void |
CallbackConnection.publish(String topic,
byte[] payload,
QoS qos,
boolean retain,
Callback<Void> cb) |
void |
BlockingConnection.publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain) |
Future<Void> |
FutureConnection.publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain) |
void |
CallbackConnection.publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain,
Callback<Void> cb) |
void |
MQTT.setWillQos(QoS willQos) |
Constructor and Description |
---|
Topic(String name,
QoS qos) |
Topic(org.fusesource.hawtbuf.UTF8Buffer name,
QoS qos) |
Modifier and Type | Method and Description |
---|---|
QoS |
UNSUBSCRIBE.qos() |
QoS |
MessageSupport.Acked.qos() |
protected QoS |
MessageSupport.HeaderBase.qos() |
QoS |
MQTTFrame.qos() |
QoS |
PUBREL.qos() |
QoS |
SUBSCRIBE.qos() |
QoS |
PUBLISH.qos() |
QoS |
CONNECT.willQos() |
Modifier and Type | Method and Description |
---|---|
protected MessageSupport.HeaderBase |
MessageSupport.HeaderBase.qos(QoS qos) |
MQTTFrame |
MQTTFrame.qos(QoS qos) |
PUBLISH |
PUBLISH.qos(QoS qos) |
CONNECT |
CONNECT.willQos(QoS willQos) |
Copyright © 2010–2018 FuseSource, Corp.. All rights reserved.