- 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 MqttSubscriptioncreate(String topicName)static MqttSubscriptioncreate(String topicName, int flags)static MqttSubscriptioncreate(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)booleanequals(Object other)intflags()inthashCode()Encoder<?,MqttSubscription>mqttEncoder(MqttEncoder mqtt)intmqttSize(MqttEncoder mqtt)MqttQoSqos()MqttSubscriptionqos(MqttQoS qos)StringtopicName()MqttSubscriptiontopicName(String topicName)StringtoString()-
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:
mqttEncoderin classMqttPart
-
encodeMqtt
public Encoder<?,MqttSubscription> encodeMqtt(OutputBuffer<?> output, MqttEncoder mqtt)
- Specified by:
encodeMqttin classMqttPart
-
debug
public <T> Output<T> debug(Output<T> output)
Description copied from interface:DebugWrites 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)
-
-