Module swim.mqtt

Package swim.mqtt

Class MqttEncoder

java.lang.Object

swim.mqtt.MqttEncoder

public class MqttEncoder
extends Object

Constructor Summary

Constructors

Constructor	Description
MqttEncoder()

Method Summary

Modifier and Type	Method	Description
Encoder<?,MqttConnAckPacket>	connAckPacketEncoder(MqttConnAckPacket packet)
Encoder<?,MqttConnectPacket>	connectPacketEncoder(MqttConnectPacket packet)
Encoder<Data,Data>	dataEncoder(Data data)
Encoder<?,MqttDisconnectPacket>	disconnectPacketEncoder(MqttDisconnectPacket packet)
Encoder<?,MqttConnAckPacket>	encodeConnAckPacket(OutputBuffer<?> output, MqttConnAckPacket packet)
Encoder<?,MqttConnectPacket>	encodeConnectPacket(OutputBuffer<?> output, MqttConnectPacket packet)
Encoder<Data,Data>	encodeData(OutputBuffer<?> output, Data data)
Encoder<?,MqttDisconnectPacket>	encodeDisconnectPacket(OutputBuffer<?> output, MqttDisconnectPacket packet)
Encoder<?,MqttPingReqPacket>	encodePingReqPacket(OutputBuffer<?> output, MqttPingReqPacket packet)
Encoder<?,MqttPingRespPacket>	encodePingRespPacket(OutputBuffer<?> output, MqttPingRespPacket packet)
Encoder<?,MqttPubAckPacket>	encodePubAckPacket(OutputBuffer<?> output, MqttPubAckPacket packet)
Encoder<?,MqttPubCompPacket>	encodePubCompPacket(OutputBuffer<?> output, MqttPubCompPacket packet)
<T> Encoder<?,MqttPublishPacket<T>>	encodePublishPacket(OutputBuffer<?> output, MqttPublishPacket<T> packet)
Encoder<?,MqttPubRecPacket>	encodePubRecPacket(OutputBuffer<?> output, MqttPubRecPacket packet)
Encoder<?,MqttPubRelPacket>	encodePubRelPacket(OutputBuffer<?> output, MqttPubRelPacket packet)
Encoder<String,String>	encodeString(OutputBuffer<?> output, String string)
Encoder<?,MqttSubAckPacket>	encodeSubAckPacket(OutputBuffer<?> output, MqttSubAckPacket packet)
Encoder<?,MqttSubscribePacket>	encodeSubscribePacket(OutputBuffer<?> output, MqttSubscribePacket packet)
Encoder<MqttSubscription,MqttSubscription>	encodeSubscription(OutputBuffer<?> output, MqttSubscription subscription)
Encoder<?,MqttUnsubAckPacket>	encodeUnsubAckPacket(OutputBuffer<?> output, MqttUnsubAckPacket packet)
Encoder<?,MqttUnsubscribePacket>	encodeUnsubscribePacket(OutputBuffer<?> output, MqttUnsubscribePacket packet)
Encoder<?,MqttPingReqPacket>	pingReqPacketEncoder(MqttPingReqPacket packet)
Encoder<?,MqttPingRespPacket>	pingRespPacketEncoder(MqttPingRespPacket packet)
Encoder<?,MqttPubAckPacket>	pubAckPacketEncoder(MqttPubAckPacket packet)
Encoder<?,MqttPubCompPacket>	pubCompPacketEncoder(MqttPubCompPacket packet)
<T> Encoder<?,MqttPublishPacket<T>>	publishPacketEncoder(MqttPublishPacket<T> packet)
Encoder<?,MqttPubRecPacket>	pubRecPacketEncoder(MqttPubRecPacket packet)
Encoder<?,MqttPubRelPacket>	pubRelPacketEncoder(MqttPubRelPacket packet)
int	sizeOfData(Data data)
int	sizeOfString(String string)
int	sizeOfSubscription(MqttSubscription subscription)
Encoder<String,String>	stringEncoder(String string)
Encoder<?,MqttSubAckPacket>	subAckPacketEncoder(MqttSubAckPacket packet)
Encoder<?,MqttSubscribePacket>	subscribePacketEncoder(MqttSubscribePacket packet)
Encoder<MqttSubscription,MqttSubscription>	subscriptionEncoder(MqttSubscription subscription)
Encoder<?,MqttUnsubAckPacket>	unsubAckPacketEncoder(MqttUnsubAckPacket packet)
Encoder<?,MqttUnsubscribePacket>	unsubscribePacketEncoder(MqttUnsubscribePacket packet)

Methods inherited from class java.lang.Object

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

Constructor Details

MqttEncoder

public MqttEncoder()

Method Details

connectPacketEncoder

public Encoder<?,MqttConnectPacket> connectPacketEncoder(MqttConnectPacket packet)

encodeConnectPacket

public Encoder<?,MqttConnectPacket> encodeConnectPacket(OutputBuffer<?> output,
 MqttConnectPacket packet)

connAckPacketEncoder

public Encoder<?,MqttConnAckPacket> connAckPacketEncoder(MqttConnAckPacket packet)

encodeConnAckPacket

public Encoder<?,MqttConnAckPacket> encodeConnAckPacket(OutputBuffer<?> output,
 MqttConnAckPacket packet)

publishPacketEncoder

public <T> Encoder<?,MqttPublishPacket<T>> publishPacketEncoder(MqttPublishPacket<T> packet)

encodePublishPacket

public <T> Encoder<?,MqttPublishPacket<T>> encodePublishPacket(OutputBuffer<?> output,
 MqttPublishPacket<T> packet)

pubAckPacketEncoder

public Encoder<?,MqttPubAckPacket> pubAckPacketEncoder(MqttPubAckPacket packet)

encodePubAckPacket

public Encoder<?,MqttPubAckPacket> encodePubAckPacket(OutputBuffer<?> output,
 MqttPubAckPacket packet)

pubRecPacketEncoder

public Encoder<?,MqttPubRecPacket> pubRecPacketEncoder(MqttPubRecPacket packet)

encodePubRecPacket

public Encoder<?,MqttPubRecPacket> encodePubRecPacket(OutputBuffer<?> output,
 MqttPubRecPacket packet)

pubRelPacketEncoder

public Encoder<?,MqttPubRelPacket> pubRelPacketEncoder(MqttPubRelPacket packet)

encodePubRelPacket

public Encoder<?,MqttPubRelPacket> encodePubRelPacket(OutputBuffer<?> output,
 MqttPubRelPacket packet)

pubCompPacketEncoder

public Encoder<?,MqttPubCompPacket> pubCompPacketEncoder(MqttPubCompPacket packet)

encodePubCompPacket

public Encoder<?,MqttPubCompPacket> encodePubCompPacket(OutputBuffer<?> output,
 MqttPubCompPacket packet)

subscribePacketEncoder

public Encoder<?,MqttSubscribePacket> subscribePacketEncoder(MqttSubscribePacket packet)

encodeSubscribePacket

public Encoder<?,MqttSubscribePacket> encodeSubscribePacket(OutputBuffer<?> output,
 MqttSubscribePacket packet)

subAckPacketEncoder

public Encoder<?,MqttSubAckPacket> subAckPacketEncoder(MqttSubAckPacket packet)

encodeSubAckPacket

public Encoder<?,MqttSubAckPacket> encodeSubAckPacket(OutputBuffer<?> output,
 MqttSubAckPacket packet)

unsubscribePacketEncoder

public Encoder<?,MqttUnsubscribePacket> unsubscribePacketEncoder(MqttUnsubscribePacket packet)

encodeUnsubscribePacket

public Encoder<?,MqttUnsubscribePacket> encodeUnsubscribePacket(OutputBuffer<?> output,
 MqttUnsubscribePacket packet)

unsubAckPacketEncoder

public Encoder<?,MqttUnsubAckPacket> unsubAckPacketEncoder(MqttUnsubAckPacket packet)

encodeUnsubAckPacket

public Encoder<?,MqttUnsubAckPacket> encodeUnsubAckPacket(OutputBuffer<?> output,
 MqttUnsubAckPacket packet)

pingReqPacketEncoder

public Encoder<?,MqttPingReqPacket> pingReqPacketEncoder(MqttPingReqPacket packet)

encodePingReqPacket

public Encoder<?,MqttPingReqPacket> encodePingReqPacket(OutputBuffer<?> output,
 MqttPingReqPacket packet)

pingRespPacketEncoder

public Encoder<?,MqttPingRespPacket> pingRespPacketEncoder(MqttPingRespPacket packet)

encodePingRespPacket

public Encoder<?,MqttPingRespPacket> encodePingRespPacket(OutputBuffer<?> output,
 MqttPingRespPacket packet)

disconnectPacketEncoder

public Encoder<?,MqttDisconnectPacket> disconnectPacketEncoder(MqttDisconnectPacket packet)

encodeDisconnectPacket

public Encoder<?,MqttDisconnectPacket> encodeDisconnectPacket(OutputBuffer<?> output,
 MqttDisconnectPacket packet)

sizeOfSubscription

public int sizeOfSubscription(MqttSubscription subscription)

subscriptionEncoder

public Encoder<MqttSubscription,MqttSubscription> subscriptionEncoder(MqttSubscription subscription)

encodeSubscription

public Encoder<MqttSubscription,MqttSubscription> encodeSubscription(OutputBuffer<?> output,
 MqttSubscription subscription)

sizeOfString

public int sizeOfString(String string)

stringEncoder

public Encoder<String,String> stringEncoder(String string)

encodeString

public Encoder<String,String> encodeString(OutputBuffer<?> output,
 String string)

sizeOfData

public int sizeOfData(Data data)

dataEncoder

public Encoder<Data,Data> dataEncoder(Data data)

encodeData

public Encoder<Data,Data> encodeData(OutputBuffer<?> output,
 Data data)