- java.lang.Object
-
- swim.mqtt.MqttDecoder
-
public class MqttDecoder extends Object
-
-
Constructor Summary
Constructors Constructor Description MqttDecoder()
-
Method Summary
-
-
-
Method Detail
-
connect
public MqttConnect connect(int packetFlags, String protocolName, int protocolLevel, int connectFlags, int keepAlive, String clientId, String willTopic, Data willMessage, String username, Data password)
-
connAck
public MqttConnAck connAck(int packetFlags, int connectFlags, int connectCode)
-
publish
public <T> MqttPublish<T> publish(int packetFlags, String topicName, int packetId, MqttEntity<T> payload)
-
pubAck
public MqttPubAck pubAck(int packetFlags, int packetId)
-
pubRec
public MqttPubRec pubRec(int packetFlags, int packetId)
-
pubRel
public MqttPubRel pubRel(int packetFlags, int packetId)
-
pubComp
public MqttPubComp pubComp(int packetFlags, int packetId)
-
subscribe
public MqttSubscribe subscribe(int packetFlags, int packetId, FingerTrieSeq<MqttSubscription> subscriptions)
-
subAck
public MqttSubAck subAck(int packetFlags, int packetId, FingerTrieSeq<MqttSubStatus> subscriptions)
-
unsubscribe
public MqttUnsubscribe unsubscribe(int packetFlags, int packetId, FingerTrieSeq<String> topicNames)
-
unsubAck
public MqttUnsubAck unsubAck(int packetFlags, int packetId)
-
pingReq
public MqttPingReq pingReq(int packetFlags)
-
pingResp
public MqttPingResp pingResp(int packetFlags)
-
disconnect
public MqttDisconnect disconnect(int packetFlags)
-
subscription
public MqttSubscription subscription(String topicName, int flags)
-
subStatus
public MqttSubStatus subStatus(int code)
-
packetDecoder
public <T> Decoder<MqttPacket<T>> packetDecoder(Decoder<T> content)
-
decodePacket
public <T> Decoder<MqttPacket<T>> decodePacket(Decoder<T> content, InputBuffer input)
-
decodePacketType
public <T> Decoder<MqttPacket<T>> decodePacketType(int packetType, Decoder<T> content, InputBuffer input)
-
decodeConnect
public Decoder<MqttConnect> decodeConnect(InputBuffer input)
-
decodeConnAck
public Decoder<MqttConnAck> decodeConnAck(InputBuffer input)
-
decodePublish
public <T> Decoder<MqttPublish<T>> decodePublish(Decoder<T> content, InputBuffer input)
-
decodePubAck
public Decoder<MqttPubAck> decodePubAck(InputBuffer input)
-
decodePubRec
public Decoder<MqttPubRec> decodePubRec(InputBuffer input)
-
decodePubRel
public Decoder<MqttPubRel> decodePubRel(InputBuffer input)
-
decodePubComp
public Decoder<MqttPubComp> decodePubComp(InputBuffer input)
-
decodeSubscribe
public Decoder<MqttSubscribe> decodeSubscribe(InputBuffer input)
-
decodeSubAck
public Decoder<MqttSubAck> decodeSubAck(InputBuffer input)
-
decodeUnsubscribe
public Decoder<MqttUnsubscribe> decodeUnsubscribe(InputBuffer input)
-
decodeUnsubAck
public Decoder<MqttUnsubAck> decodeUnsubAck(InputBuffer input)
-
decodePingReq
public Decoder<MqttPingReq> decodePingReq(InputBuffer input)
-
decodePingResp
public Decoder<MqttPingResp> decodePingResp(InputBuffer input)
-
decodeDisconnect
public Decoder<MqttDisconnect> decodeDisconnect(InputBuffer input)
-
subscriptionDecoder
public Decoder<MqttSubscription> subscriptionDecoder()
-
decodeSubscription
public Decoder<MqttSubscription> decodeSubscription(InputBuffer input)
-
decodeString
public Decoder<String> decodeString(InputBuffer input)
-
decodeData
public Decoder<Data> decodeData(InputBuffer input)
-
-