2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
20#ifndef IOT_MQTT_FIXEDHEADER_H
21#define IOT_MQTT_FIXEDHEADER_H
23#include "iot/mqtt/types/UInt8.h"
24#include "iot/mqtt/types/UIntV.h"
30#ifndef DOXYGEN_SHOULD_SKIP_THIS
43 FixedHeader(uint8_t type, uint8_t flags, uint32_t remainingLength = 0);
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)
MqttContext * mqttContext
const std::string & getConnectionName() const
virtual void onConnected()
static std::string toHexString(const std::vector< char > &data)
virtual void onPubcomp(const iot::mqtt::packets::Pubcomp &pubcomp)
virtual void onPublish(const iot::mqtt::packets::Publish &publish)
core::timer::Timer keepAliveTimer
iot::mqtt::FixedHeader fixedHeader
const MqttContext * getMqttContext() const
std::size_t onReceivedFromPeer()
virtual void onDisconnected()
void send(const std::vector< char > &data) const
void setMqttContext(MqttContext *mqttContext)
void sendPuback(uint16_t packetIdentifier) const
virtual void onPuback(const iot::mqtt::packets::Puback &puback)
std::string connectionName
void _onPubrec(const iot::mqtt::packets::Pubrec &pubrec)
virtual void deliverPacket(iot::mqtt::ControlPacketDeserializer *controlPacketDeserializer)=0
Mqtt(const std::string &connectionName, const std::string &clientId)
void sendPubrel(uint16_t packetIdentifier) const
uint16_t getPacketIdentifier()
bool _onPublish(const iot::mqtt::packets::Publish &publish)
virtual iot::mqtt::ControlPacketDeserializer * createControlPacketDeserializer(iot::mqtt::FixedHeader &staticHeader)=0
Mqtt & operator=(Mqtt &&)=delete
void sendPublish(const std::string &topic, const std::string &message, uint8_t qoS, bool retain)
void printFixedHeader(const iot::mqtt::FixedHeader &fixedHeader) const
uint16_t _packetIdentifier
Mqtt(const Mqtt &)=delete
void _onPubrel(const iot::mqtt::packets::Pubrel &pubrel)
virtual void onPubrec(const iot::mqtt::packets::Pubrec &pubrec)
virtual void onPubrel(const iot::mqtt::packets::Pubrel &pubrel)
void send(const iot::mqtt::ControlPacket &controlPacket) const
virtual bool onSignal(int sig)=0
Mqtt(const std::string &connectionName)
void initSession(Session *session, utils::Timeval keepAlive)
Mqtt & operator=(const Mqtt &)=delete
void printVP(const iot::mqtt::ControlPacket &packet) const
iot::mqtt::ControlPacketDeserializer * controlPacketDeserializer
void sendPubcomp(uint16_t packetIdentifier) const
void sendPubrec(uint16_t packetIdentifier) const
void _onPubcomp(const iot::mqtt::packets::Pubcomp &pubcomp)
void _onPuback(const iot::mqtt::packets::Puback &puback)
virtual void deliverPacket(iot::mqtt::client::Mqtt *mqtt)=0
~ControlPacketDeserializer() override
void _onPublish(const iot::mqtt::client::packets::Publish &publish)
void sendConnect(uint16_t keepAlive, const std::string &clientId, bool cleanSession, const std::string &willTopic, const std::string &willMessage, uint8_t willQoS, bool willRetain, const std::string &username, const std::string &password, bool loopPrevention=false)
iot::mqtt::Session session
std::string sessionStoreFileName
void _onPingresp(const iot::mqtt::client::packets::Pingresp &pingresp)
virtual void onConnack(const iot::mqtt::packets::Connack &connack)
virtual void onPingresp(const iot::mqtt::packets::Pingresp &pingresp)
void sendSubscribe(const std::list< Topic > &topics)
iot::mqtt::ControlPacketDeserializer * createControlPacketDeserializer(iot::mqtt::FixedHeader &fixedHeader) final
void _onSuback(const iot::mqtt::client::packets::Suback &suback)
virtual void onUnsuback(const iot::mqtt::packets::Unsuback &unsuback)
void _onConnack(const iot::mqtt::client::packets::Connack &connack)
void _onUnsuback(const iot::mqtt::client::packets::Unsuback &unsuback)
void sendUnsubscribe(const std::list< std::string > &topics)
bool onSignal(int sig) override
virtual void onSuback(const iot::mqtt::packets::Suback &suback)
void deliverPacket(iot::mqtt::ControlPacketDeserializer *controlPacketDeserializer) override
void sendDisconnect() const
Mqtt(const std::string &connectionName, const std::string &clientId)
core::timer::Timer pingTimer
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
UInt8 & operator=(const uint8_t &newValue)
UInt8(UInt8 &&) noexcept=default
UInt8 & operator=(UInt8 &&) noexcept=default
UInt8 & operator=(const UInt8 &)=default
UInt8(const UInt8 &)=default
#define MQTT_CONNACK_FLAGS