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_PACKETS_PINGREQ_H
43#define IOT_MQTT_PACKETS_PINGREQ_H
45#include "iot/mqtt/ControlPacket.h"
47#ifndef DOXYGEN_SHOULD_SKIP_THIS
Timer & operator=(Timer &&timer) noexcept=default
static Timer intervalTimer(const std::function< void()> &dispatcher, const utils::Timeval &timeout)
virtual void end(bool fatal=false)=0
MqttContext * mqttContext
virtual void onPublish(const iot::mqtt::packets::Publish &publish)
std::string connectionName
Mqtt(const std::string &connectionName, const std::string &clientId)
uint16_t getPacketIdentifier()
bool _onPublish(const iot::mqtt::packets::Publish &publish)
void send(const iot::mqtt::ControlPacket &controlPacket) const
void initSession(Session *session, utils::Timeval keepAlive)
virtual nlohmann::json toJson() const
void fromJson(const nlohmann::json &json)
virtual void deliverPacket(iot::mqtt::client::Mqtt *mqtt)=0
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
Mqtt(const std::string &connectionName, const std::string &clientId, const 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
core::timer::Timer pingTimer
Connack(uint32_t remainingLength, uint8_t flags)
Pingresp(uint32_t remainingLength, uint8_t flags)
Puback(uint32_t remainingLength, uint8_t flags)
Pubcomp(uint32_t remainingLength, uint8_t flags)
Publish(uint32_t remainingLength, uint8_t flags)
Pubrec(uint32_t remainingLength, uint8_t flags)
Pubrel(uint32_t remainingLength, uint8_t flags)
Suback(uint32_t remainingLength, uint8_t flags)
Unsuback(uint32_t remainingLength, uint8_t flags)
uint8_t getReturnCode() const
bool getSessionPresent() const
uint8_t getAcknowledgeFlags() const
iot::mqtt::types::String willMessage
iot::mqtt::types::String protocol
Connect(const std::string &clientId, uint16_t keepAlive, 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)
uint8_t getWillQoS() const
std::string getClientId() const
std::string getWillTopic() const
uint16_t getKeepAlive() const
bool getUsernameFlag() const
bool getCleanSession() const
iot::mqtt::types::String willTopic
std::vector< char > serializeVP() const override
std::string getUsername() const
uint8_t getConnectFlags() const
bool getPasswordFlag() const
iot::mqtt::types::UInt8 connectFlags
std::string getPassword() const
iot::mqtt::types::String username
iot::mqtt::types::UInt8 level
std::string getWillMessage() const
bool getWillRetain() const
iot::mqtt::types::String clientId
iot::mqtt::types::String password
std::string getProtocol() const
iot::mqtt::types::UInt16 keepAlive
std::vector< char > serializeVP() const override
std::vector< char > serializeVP() const override
uint16_t getPacketIdentifier() const
const std::list< uint8_t > & getReturnCodes() const
Subscribe(uint16_t packetIdentifier, const std::list< iot::mqtt::Topic > &topics)
uint16_t getPacketIdentifier() const
Unsubscribe(uint16_t packetIdentifier, const std::list< std::string > &topics)
#define MQTT_CONNACK_ACCEPT