2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef IOT_MQTT_CONTROLPACKET_H
43#define IOT_MQTT_CONTROLPACKET_H
45#ifndef DOXYGEN_SHOULD_SKIP_THIS
53#define MQTT_RESERVED_00 0x00
54#define MQTT_CONNECT 0x01
55#define MQTT_CONNACK 0x02
56#define MQTT_PUBLISH 0x03
57#define MQTT_PUBACK 0x04
58#define MQTT_PUBREC 0x05
59#define MQTT_PUBREL 0x06
60#define MQTT_PUBCOMP 0x07
61#define MQTT_SUBSCRIBE 0x08
62#define MQTT_SUBACK 0x09
63#define MQTT_UNSUBSCRIBE 0x0A
64#define MQTT_UNSUBACK 0x0B
65#define MQTT_PINGREQ 0x0C
66#define MQTT_PINGRESP 0x0D
67#define MQTT_DISCONNECT 0x0E
68#define MQTT_RESERVED_0F 0x0F
71#define MQTT_CONNECT_FLAGS 0x00
72#define MQTT_CONNACK_FLAGS 0x00
74#define MQTT_PUBACK_FLAGS 0x00
75#define MQTT_PUBREC_FLAGS 0x00
76#define MQTT_PUBREL_FLAGS 0x02
77#define MQTT_PUBCOMP_FLAGS 0x00
78#define MQTT_SUBSCRIBE_FLAGS 0x02
79#define MQTT_SUBACK_FLAGS 0x00
80#define MQTT_UNSUBSCRIBE_FLAGS 0x02
81#define MQTT_UNSUBACK_FLAGS 0x00
82#define MQTT_PINGREQ_FLAGS 0x00
83#define MQTT_PINGRESP_FLAGS 0x00
84#define MQTT_DISCONNECT_FLAGS 0x00
105 const std::string&
getName()
const;
std::size_t deserialize(iot::mqtt::MqttContext *mqttContext)
virtual ~ControlPacketDeserializer()
std::size_t getConsumed() const
virtual std::size_t deserializeVP(iot::mqtt::MqttContext *mqttContext)=0
uint32_t getRemainingLength() const
ControlPacketDeserializer()=default
ControlPacketDeserializer & operator=(const ControlPacketDeserializer &)=default
ControlPacketDeserializer(uint32_t remainingLength, uint8_t flags, uint8_t mustFlags)
std::vector< char > serialize() const
const std::string & getName() const
ControlPacket & operator=(const ControlPacket &)=default
virtual std::vector< char > serializeVP() const =0
ControlPacket(const ControlPacket &)=default
ControlPacket(ControlPacket &&)=default
ControlPacket(uint8_t type, const std::string &name)
ControlPacket & operator=(ControlPacket &&)=default
void printVP(const iot::mqtt::ControlPacket &packet) const
virtual void deliverPacket(iot::mqtt::client::Mqtt *mqtt)=0
~ControlPacketDeserializer() override
void _onConnack(const iot::mqtt::client::packets::Connack &connack)
std::size_t deserializeVP(iot::mqtt::MqttContext *mqttContext) override
Connack(uint32_t remainingLength, uint8_t flags)
void deliverPacket(iot::mqtt::client::Mqtt *mqtt) override
uint8_t getReturnCode() const
std::vector< char > serializeVP() const override
Connack(uint8_t returncode, uint8_t acknowledgeFlags)
iot::mqtt::types::UInt8 acknowledgeFlags
bool getSessionPresent() const
uint8_t getAcknowledgeFlags() const
iot::mqtt::types::UInt8 returnCode
virtual std::size_t deserialize(iot::mqtt::MqttContext *mqttContext)
#define MQTT_CONNACK_FLAGS
const std::vector< std::string > mqttPackageName