- java.lang.Object
-
- swim.mqtt.MqttEncoder
-
public class MqttEncoder extends Object
-
-
Constructor Summary
Constructors Constructor Description MqttEncoder()
-
Method Summary
-
-
-
Method Detail
-
connectEncoder
public Encoder<?,MqttConnect> connectEncoder(MqttConnect packet)
-
encodeConnect
public Encoder<?,MqttConnect> encodeConnect(MqttConnect packet, OutputBuffer<?> output)
-
connAckEncoder
public Encoder<?,MqttConnAck> connAckEncoder(MqttConnAck packet)
-
encodeConnAck
public Encoder<?,MqttConnAck> encodeConnAck(MqttConnAck packet, OutputBuffer<?> output)
-
publishEncoder
public <T> Encoder<?,MqttPublish<T>> publishEncoder(MqttPublish<T> packet)
-
encodePublish
public <T> Encoder<?,MqttPublish<T>> encodePublish(MqttPublish<T> packet, OutputBuffer<?> output)
-
pubAckEncoder
public Encoder<?,MqttPubAck> pubAckEncoder(MqttPubAck packet)
-
encodePubAck
public Encoder<?,MqttPubAck> encodePubAck(MqttPubAck packet, OutputBuffer<?> output)
-
pubRecEncoder
public Encoder<?,MqttPubRec> pubRecEncoder(MqttPubRec packet)
-
encodePubRec
public Encoder<?,MqttPubRec> encodePubRec(MqttPubRec packet, OutputBuffer<?> output)
-
pubRelEncoder
public Encoder<?,MqttPubRel> pubRelEncoder(MqttPubRel packet)
-
encodePubRel
public Encoder<?,MqttPubRel> encodePubRel(MqttPubRel packet, OutputBuffer<?> output)
-
pubCompEncoder
public Encoder<?,MqttPubComp> pubCompEncoder(MqttPubComp packet)
-
encodePubComp
public Encoder<?,MqttPubComp> encodePubComp(MqttPubComp packet, OutputBuffer<?> output)
-
subscribeEncoder
public Encoder<?,MqttSubscribe> subscribeEncoder(MqttSubscribe packet)
-
encodeSubscribe
public Encoder<?,MqttSubscribe> encodeSubscribe(MqttSubscribe packet, OutputBuffer<?> output)
-
subAckEncoder
public Encoder<?,MqttSubAck> subAckEncoder(MqttSubAck packet)
-
encodeSubAck
public Encoder<?,MqttSubAck> encodeSubAck(MqttSubAck packet, OutputBuffer<?> output)
-
unsubscribeEncoder
public Encoder<?,MqttUnsubscribe> unsubscribeEncoder(MqttUnsubscribe packet)
-
encodeUnsubscribe
public Encoder<?,MqttUnsubscribe> encodeUnsubscribe(MqttUnsubscribe packet, OutputBuffer<?> output)
-
unsubAckEncoder
public Encoder<?,MqttUnsubAck> unsubAckEncoder(MqttUnsubAck packet)
-
encodeUnsubAck
public Encoder<?,MqttUnsubAck> encodeUnsubAck(MqttUnsubAck packet, OutputBuffer<?> output)
-
pingReqEncoder
public Encoder<?,MqttPingReq> pingReqEncoder(MqttPingReq packet)
-
encodePingReq
public Encoder<?,MqttPingReq> encodePingReq(MqttPingReq packet, OutputBuffer<?> output)
-
pingRespEncoder
public Encoder<?,MqttPingResp> pingRespEncoder(MqttPingResp packet)
-
encodePingResp
public Encoder<?,MqttPingResp> encodePingResp(MqttPingResp packet, OutputBuffer<?> output)
-
disconnectEncoder
public Encoder<?,MqttDisconnect> disconnectEncoder(MqttDisconnect packet)
-
encodeDisconnect
public Encoder<?,MqttDisconnect> encodeDisconnect(MqttDisconnect packet, OutputBuffer<?> output)
-
sizeOfSubscription
public int sizeOfSubscription(MqttSubscription subscription)
-
subscriptionEncoder
public Encoder<MqttSubscription,MqttSubscription> subscriptionEncoder(MqttSubscription subscription)
-
encodeSubscription
public Encoder<MqttSubscription,MqttSubscription> encodeSubscription(MqttSubscription subscription, OutputBuffer<?> output)
-
sizeOfString
public int sizeOfString(String string)
-
encodeString
public Encoder<String,String> encodeString(String string, OutputBuffer<?> output)
-
sizeOfData
public int sizeOfData(Data data)
-
encodeData
public Encoder<Data,Data> encodeData(Data data, OutputBuffer<?> output)
-
-