Module swim.mqtt

Package swim.mqtt

Class MqttDecoder

java.lang.Object

swim.mqtt.MqttDecoder

public class MqttDecoder
extends Object

Constructor Summary

Constructors

Constructor	Description
MqttDecoder()

Method Summary

Modifier and Type	Method	Description
MqttConnAckPacket	connAckPacket(int packetFlags, int connectFlags, int connectCode)
MqttConnectPacket	connectPacket(int packetFlags, String protocolName, int protocolLevel, int connectFlags, int keepAlive, String clientId, String willTopic, Data willMessage, String username, Data password)
Decoder<Data>	dataDecoder()
Decoder<MqttConnAckPacket>	decodeConnAckPacket(InputBuffer input)
Decoder<MqttConnectPacket>	decodeConnectPacket(InputBuffer input)
Decoder<Data>	decodeData(InputBuffer input)
Decoder<MqttDisconnectPacket>	decodeDisconnectPacket(InputBuffer input)
<T> Decoder<MqttPacket<T>>	decodePacket(InputBuffer input, Decoder<T> payloadDecoder)
<T> Decoder<MqttPacket<T>>	decodePacketType(InputBuffer input, int packetType, Decoder<T> payloadDecoder)
Decoder<MqttPingReqPacket>	decodePingReqPacket(InputBuffer input)
Decoder<MqttPingRespPacket>	decodePingRespPacket(InputBuffer input)
Decoder<MqttPubAckPacket>	decodePubAckPacket(InputBuffer input)
Decoder<MqttPubCompPacket>	decodePubCompPacket(InputBuffer input)
<T> Decoder<MqttPublishPacket<T>>	decodePublishPacket(InputBuffer input, Decoder<T> payloadDecoder)
Decoder<MqttPubRecPacket>	decodePubRecPacket(InputBuffer input)
Decoder<MqttPubRelPacket>	decodePubRelPacket(InputBuffer input)
Decoder<String>	decodeString(InputBuffer input)
Decoder<MqttSubAckPacket>	decodeSubAckPacket(InputBuffer input)
Decoder<MqttSubscribePacket>	decodeSubscribePacket(InputBuffer input)
Decoder<MqttSubscription>	decodeSubscription(InputBuffer input)
Decoder<MqttUnsubAckPacket>	decodeUnsubAckPacket(InputBuffer input)
Decoder<MqttUnsubscribePacket>	decodeUnsubscribePacket(InputBuffer input)
MqttDisconnectPacket	disconnectPacket(int packetFlags)
<T> Decoder<MqttPacket<T>>	packetDecoder(Decoder<T> payloadDecoder)
MqttPingReqPacket	pingReqPacket(int packetFlags)
MqttPingRespPacket	pingRespPacket(int packetFlags)
MqttPubAckPacket	pubAckPacket(int packetFlags, int packetId)
MqttPubCompPacket	pubCompPacket(int packetFlags, int packetId)
<T> MqttPublishPacket<T>	publishPacket(int packetFlags, String topicName, int packetId, T payloadValue)
MqttPubRecPacket	pubRecPacket(int packetFlags, int packetId)
MqttPubRelPacket	pubRelPacket(int packetFlags, int packetId)
Decoder<String>	stringDecoder()
MqttSubAckPacket	subAckPacket(int packetFlags, int packetId, FingerTrieSeq<MqttSubStatus> subscriptions)
MqttSubscribePacket	subscribePacket(int packetFlags, int packetId, FingerTrieSeq<MqttSubscription> subscriptions)
MqttSubscription	subscription(String topicName, int flags)
Decoder<MqttSubscription>	subscriptionDecoder()
MqttSubStatus	subStatus(int code)
MqttUnsubAckPacket	unsubAckPacket(int packetFlags, int packetId)
MqttUnsubscribePacket	unsubscribePacket(int packetFlags, int packetId, FingerTrieSeq<String> topicNames)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MqttDecoder

public MqttDecoder()

Method Details

connectPacket

public MqttConnectPacket connectPacket(int packetFlags,
 String protocolName,
 int protocolLevel,
 int connectFlags,
 int keepAlive,
 String clientId,
 String willTopic,
 Data willMessage,
 String username,
 Data password)

connAckPacket

public MqttConnAckPacket connAckPacket(int packetFlags,
 int connectFlags,
 int connectCode)

publishPacket

public <T> MqttPublishPacket<T> publishPacket(int packetFlags,
 String topicName,
 int packetId,
 T payloadValue)

pubAckPacket

public MqttPubAckPacket pubAckPacket(int packetFlags,
 int packetId)

pubRecPacket

public MqttPubRecPacket pubRecPacket(int packetFlags,
 int packetId)

pubRelPacket

public MqttPubRelPacket pubRelPacket(int packetFlags,
 int packetId)

pubCompPacket

public MqttPubCompPacket pubCompPacket(int packetFlags,
 int packetId)

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

public MqttUnsubAckPacket unsubAckPacket(int packetFlags,
 int packetId)

pingReqPacket

public MqttPingReqPacket pingReqPacket(int packetFlags)

pingRespPacket

public MqttPingRespPacket pingRespPacket(int packetFlags)

disconnectPacket

public MqttDisconnectPacket disconnectPacket(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> payloadDecoder)

decodePacket

public <T> Decoder<MqttPacket<T>> decodePacket(InputBuffer input,
 Decoder<T> payloadDecoder)

decodePacketType

public <T> Decoder<MqttPacket<T>> decodePacketType(InputBuffer input,
 int packetType,
 Decoder<T> payloadDecoder)

decodeConnectPacket

public Decoder<MqttConnectPacket> decodeConnectPacket(InputBuffer input)

decodeConnAckPacket

public Decoder<MqttConnAckPacket> decodeConnAckPacket(InputBuffer input)

decodePublishPacket

public <T> Decoder<MqttPublishPacket<T>> decodePublishPacket(InputBuffer input,
 Decoder<T> payloadDecoder)

decodePubAckPacket

public Decoder<MqttPubAckPacket> decodePubAckPacket(InputBuffer input)

decodePubRecPacket

public Decoder<MqttPubRecPacket> decodePubRecPacket(InputBuffer input)

decodePubRelPacket

public Decoder<MqttPubRelPacket> decodePubRelPacket(InputBuffer input)

decodePubCompPacket

public Decoder<MqttPubCompPacket> decodePubCompPacket(InputBuffer input)

decodeSubscribePacket

public Decoder<MqttSubscribePacket> decodeSubscribePacket(InputBuffer input)

decodeSubAckPacket

public Decoder<MqttSubAckPacket> decodeSubAckPacket(InputBuffer input)

decodeUnsubscribePacket

public Decoder<MqttUnsubscribePacket> decodeUnsubscribePacket(InputBuffer input)

decodeUnsubAckPacket

public Decoder<MqttUnsubAckPacket> decodeUnsubAckPacket(InputBuffer input)

decodePingReqPacket

public Decoder<MqttPingReqPacket> decodePingReqPacket(InputBuffer input)

decodePingRespPacket

public Decoder<MqttPingRespPacket> decodePingRespPacket(InputBuffer input)

decodeDisconnectPacket

public Decoder<MqttDisconnectPacket> decodeDisconnectPacket(InputBuffer input)

subscriptionDecoder

public Decoder<MqttSubscription> subscriptionDecoder()

decodeSubscription

public Decoder<MqttSubscription> decodeSubscription(InputBuffer input)

stringDecoder

public Decoder<String> stringDecoder()

decodeString

public Decoder<String> decodeString(InputBuffer input)

dataDecoder

public Decoder<Data> dataDecoder()

decodeData

public Decoder<Data> decodeData(InputBuffer input)