java.lang.Object
swim.mqtt.MqttDecoder
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionconnAckPacket
(int packetFlags, int connectFlags, int connectCode) connectPacket
(int packetFlags, String protocolName, int protocolLevel, int connectFlags, int keepAlive, String clientId, String willTopic, Data willMessage, String username, Data password) decodeConnAckPacket
(InputBuffer input) decodeConnectPacket
(InputBuffer input) decodeData
(InputBuffer input) <T> Decoder<MqttPacket<T>>
decodePacket
(InputBuffer input, Decoder<T> payloadDecoder) <T> Decoder<MqttPacket<T>>
decodePacketType
(InputBuffer input, int packetType, Decoder<T> payloadDecoder) decodePingReqPacket
(InputBuffer input) decodePingRespPacket
(InputBuffer input) decodePubAckPacket
(InputBuffer input) decodePubCompPacket
(InputBuffer input) <T> Decoder<MqttPublishPacket<T>>
decodePublishPacket
(InputBuffer input, Decoder<T> payloadDecoder) decodePubRecPacket
(InputBuffer input) decodePubRelPacket
(InputBuffer input) decodeString
(InputBuffer input) decodeSubAckPacket
(InputBuffer input) decodeSubscribePacket
(InputBuffer input) decodeSubscription
(InputBuffer input) decodeUnsubAckPacket
(InputBuffer input) disconnectPacket
(int packetFlags) <T> Decoder<MqttPacket<T>>
packetDecoder
(Decoder<T> payloadDecoder) pingReqPacket
(int packetFlags) pingRespPacket
(int packetFlags) pubAckPacket
(int packetFlags, int packetId) pubCompPacket
(int packetFlags, int packetId) <T> MqttPublishPacket<T>
publishPacket
(int packetFlags, String topicName, int packetId, T payloadValue) pubRecPacket
(int packetFlags, int packetId) pubRelPacket
(int packetFlags, int packetId) subAckPacket
(int packetFlags, int packetId, FingerTrieSeq<MqttSubStatus> subscriptions) subscribePacket
(int packetFlags, int packetId, FingerTrieSeq<MqttSubscription> subscriptions) subscription
(String topicName, int flags) subStatus
(int code) unsubAckPacket
(int packetFlags, int packetId) unsubscribePacket
(int packetFlags, int packetId, FingerTrieSeq<String> topicNames)
-
Constructor Details
-
MqttDecoder
public MqttDecoder()
-
-
Method Details
-
connectPacket
-
connAckPacket
-
publishPacket
public <T> MqttPublishPacket<T> publishPacket(int packetFlags, String topicName, int packetId, T payloadValue) -
pubAckPacket
-
pubRecPacket
-
pubRelPacket
-
pubCompPacket
-
subscribePacket
public MqttSubscribePacket subscribePacket(int packetFlags, int packetId, FingerTrieSeq<MqttSubscription> subscriptions) -
subAckPacket
public MqttSubAckPacket subAckPacket(int packetFlags, int packetId, FingerTrieSeq<MqttSubStatus> subscriptions) -
unsubscribePacket
public MqttUnsubscribePacket unsubscribePacket(int packetFlags, int packetId, FingerTrieSeq<String> topicNames) -
unsubAckPacket
-
pingReqPacket
-
pingRespPacket
-
disconnectPacket
-
subscription
-
subStatus
-
packetDecoder
-
decodePacket
-
decodePacketType
public <T> Decoder<MqttPacket<T>> decodePacketType(InputBuffer input, int packetType, Decoder<T> payloadDecoder) -
decodeConnectPacket
-
decodeConnAckPacket
-
decodePublishPacket
public <T> Decoder<MqttPublishPacket<T>> decodePublishPacket(InputBuffer input, Decoder<T> payloadDecoder) -
decodePubAckPacket
-
decodePubRecPacket
-
decodePubRelPacket
-
decodePubCompPacket
-
decodeSubscribePacket
-
decodeSubAckPacket
-
decodeUnsubscribePacket
-
decodeUnsubAckPacket
-
decodePingReqPacket
-
decodePingRespPacket
-
decodeDisconnectPacket
-
subscriptionDecoder
-
decodeSubscription
-
stringDecoder
-
decodeString
-
dataDecoder
-
decodeData
-