mqtt::mqttintegrator::lib::Mqtt Class Reference

#include <Mqtt.h>

Inheritance diagram for mqtt::mqttintegrator::lib::Mqtt:

Collaboration diagram for mqtt::mqttintegrator::lib::Mqtt:

Public Member Functions
	Mqtt (const std::string &connectionName, const nlohmann::json &connectionJson, const nlohmann::json &mappingJson, const std::string &sessionStoreFileName)
Public Member Functions inherited from mqtt::lib::MqttMapper
	MqttMapper (const nlohmann::json &mappingJson)
	MqttMapper (const MqttMapper &)=delete
MqttMapper &	operator= (const MqttMapper &)=delete
virtual	~MqttMapper ()

Private Types
using	Super = iot::mqtt::client::Mqtt

Private Member Functions
void	onConnected () final
bool	onSignal (int signum) final
void	onConnack (const iot::mqtt::packets::Connack &connack) final
void	onPublish (const iot::mqtt::packets::Publish &publish) final
void	publishMapping (const std::string &topic, const std::string &message, uint8_t qoS, bool retain) final

Private Attributes
const nlohmann::json &	connectionJson

Additional Inherited Members
Protected Member Functions inherited from mqtt::lib::MqttMapper
std::string	dump ()
std::list< iot::mqtt::Topic >	extractSubscriptions ()
void	publishMappings (const iot::mqtt::packets::Publish &publish)

Detailed Description

Definition at line 58 of file Mqtt.h.

Member Typedef Documentation

Super

using mqtt::mqttintegrator::lib::Mqtt::Super = iot::mqtt::client::Mqtt

private

Definition at line 68 of file Mqtt.h.

Constructor & Destructor Documentation

Mqtt()

mqtt::mqttintegrator::lib::Mqtt::Mqtt ( const std::string & connectionName, const nlohmann::json & connectionJson, const nlohmann::json & mappingJson, const std::string & sessionStoreFileName )

explicit

Definition at line 60 of file Mqtt.cpp.

        : iot::mqtt::client::Mqtt(connectionName, //
                                  connectionJson["client_id"],
                                  connectionJson["keep_alive"],
                                  sessionStoreFileName)
        , mqtt::lib::MqttMapper(mappingJson)
        , connectionJson(connectionJson) {
        VLOG(1) << "Client Id: " << clientId;
        VLOG(1) << "  Keep Alive: " << keepAlive;
        VLOG(1) << "  Clean Session: " << connectionJson["clean_session"];
        VLOG(1) << "  Will Topic: " << connectionJson["will_topic"];
        VLOG(1) << "  Will Message: " << connectionJson["will_message"];
        VLOG(1) << "  Will QoS: " << static_cast<uint16_t>(connectionJson["will_qos"]);
        VLOG(1) << "  Will Retain " << connectionJson["will_retain"];
        VLOG(1) << "  Username: " << connectionJson["username"];
        VLOG(1) << "  Password: " << connectionJson["password"];
    }

References connectionJson, and mqtt::lib::MqttMapper::MqttMapper().

Referenced by mqtt::mqttintegrator::SocketContextFactory::create().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

onConnack()

void mqtt::mqttintegrator::lib::Mqtt::onConnack ( const iot::mqtt::packets::Connack & connack )

finalprivate

Definition at line 102 of file Mqtt.cpp.

                                                             {
        if (connack.getReturnCode() == 0 && !connack.getSessionPresent()) {
            sendPublish("snode.c/_cfg_/connection", connectionJson.dump(), 0, true);
 
            const std::list<iot::mqtt::Topic> topicList = MqttMapper::extractSubscriptions();
 
            for (const iot::mqtt::Topic& topic : topicList) {
                VLOG(1) << "MQTT: Subscribe Topic: " << topic.getName() << ", qoS: " << static_cast<uint16_t>(topic.getQoS());
            }
 
            sendSubscribe(topicList);
        }
    }

References connectionJson, and mqtt::lib::MqttMapper::extractSubscriptions().

Here is the call graph for this function:

onConnected()

void mqtt::mqttintegrator::lib::Mqtt::onConnected ( )

finalprivate

Definition at line 81 of file Mqtt.cpp.

                           {
        VLOG(1) << "MQTT: Initiating Session";
 
        sendConnect(connectionJson["clean_session"],
                    connectionJson["will_topic"],
                    connectionJson["will_message"],
                    connectionJson["will_qos"],
                    connectionJson["will_retain"],
                    connectionJson["username"],
                    connectionJson["password"]);
    }

References connectionJson.

onPublish()

void mqtt::mqttintegrator::lib::Mqtt::onPublish ( const iot::mqtt::packets::Publish & publish )

finalprivate

Definition at line 116 of file Mqtt.cpp.

                                                             {
        publishMappings(publish);
    }

References mqtt::lib::MqttMapper::publishMappings().

Here is the call graph for this function:

onSignal()

bool mqtt::mqttintegrator::lib::Mqtt::onSignal ( int signum )

nodiscardfinalprivate

Definition at line 93 of file Mqtt.cpp.

                                  {
        VLOG(1) << "MQTT: On Exit due to '" << strsignal(signum) << "' (SIG" << utils::system::sigabbrev_np(signum) << " = " << signum
                << ")";
 
        sendDisconnect();
 
        return Super::onSignal(signum);
    }

publishMapping()

void mqtt::mqttintegrator::lib::Mqtt::publishMapping ( const std::string & topic, const std::string & message, uint8_t qoS, bool retain )

finalprivatevirtual

Implements mqtt::lib::MqttMapper.

Definition at line 120 of file Mqtt.cpp.

                                                                                                        {
        sendPublish(topic, message, qoS, retain);
    }

Member Data Documentation

connectionJson

const nlohmann::json& mqtt::mqttintegrator::lib::Mqtt::connectionJson

private

Definition at line 78 of file Mqtt.h.

Referenced by Mqtt(), onConnack(), and onConnected().

---

The documentation for this class was generated from the following files:

• mqttintegrator/lib/Mqtt.h
• mqttintegrator/lib/Mqtt.cpp