- java.lang.Object
-
- swim.mqtt.MqttPart
-
- swim.mqtt.MqttSubscription
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static MqttSubscription
create(String topicName)
static MqttSubscription
create(String topicName, int flags)
static MqttSubscription
create(String topicName, MqttQoS qos)
<T> Output<T>
debug(Output<T> output)
Writes a developer readable, debug-formatted string representation of this object tooutput
.Encoder<?,MqttSubscription>
encodeMqtt(OutputBuffer<?> output, MqttEncoder mqtt)
boolean
equals(Object other)
int
flags()
int
hashCode()
Encoder<?,MqttSubscription>
mqttEncoder(MqttEncoder mqtt)
int
mqttSize(MqttEncoder mqtt)
MqttQoS
qos()
MqttSubscription
qos(MqttQoS qos)
String
topicName()
MqttSubscription
topicName(String topicName)
String
toString()
-
Methods inherited from class swim.mqtt.MqttPart
encodeMqtt, mqttEncoder
-
-
-
-
Method Detail
-
topicName
public String topicName()
-
topicName
public MqttSubscription topicName(String topicName)
-
flags
public int flags()
-
qos
public MqttQoS qos()
-
qos
public MqttSubscription qos(MqttQoS qos)
-
mqttSize
public int mqttSize(MqttEncoder mqtt)
-
mqttEncoder
public Encoder<?,MqttSubscription> mqttEncoder(MqttEncoder mqtt)
- Specified by:
mqttEncoder
in classMqttPart
-
encodeMqtt
public Encoder<?,MqttSubscription> encodeMqtt(OutputBuffer<?> output, MqttEncoder mqtt)
- Specified by:
encodeMqtt
in classMqttPart
-
debug
public <T> Output<T> debug(Output<T> output)
Description copied from interface:Debug
Writes a developer readable, debug-formatted string representation of this object tooutput
.
-
create
public static MqttSubscription create(String topicName, int flags)
-
create
public static MqttSubscription create(String topicName, MqttQoS qos)
-
create
public static MqttSubscription create(String topicName)
-
-