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)
 
bool _onPublish(const iot::mqtt::packets::Publish &publish)
 
void send(const iot::mqtt::ControlPacket &controlPacket) const
 
void initSession(Session *session, utils::Timeval keepAlive)
 
uint16_t getPacketIdentifier() const
 
virtual nlohmann::json toJson() const
 
void fromJson(const nlohmann::json &json)
 
virtual void deliverPacket(iot::mqtt::client::Mqtt *mqtt)=0
 
Mqtt(const std::string &connectionName, const std::string &clientId, uint16_t keepAlive, const std::string &sessionStoreFileName)
 
void _onPublish(const iot::mqtt::client::packets::Publish &publish)
 
void sendConnect(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) const
 
iot::mqtt::Session session
 
std::string sessionStoreFileName
 
void sendUnsubscribe(const std::list< std::string > &topics) const
 
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) const
 
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)
 
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