mqtt::mqttbroker::lib::Mqtt Class Reference

#include <Mqtt.h>

Inheritance diagram for mqtt::mqttbroker::lib::Mqtt:

Collaboration diagram for mqtt::mqttbroker::lib::Mqtt:

Public Member Functions
	Mqtt (const std::string &connectionName, const std::shared_ptr< iot::mqtt::server::broker::Broker > &broker, const nlohmann::json &mappingJson)
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 Member Functions
void	onConnect (const iot::mqtt::packets::Connect &connect) final
void	onPublish (const iot::mqtt::packets::Publish &publish) final
void	onDisconnected () final
void	publishMapping (const std::string &topic, const std::string &message, uint8_t qoS, bool retain) final

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 63 of file Mqtt.h.

Constructor & Destructor Documentation

Mqtt()

mqtt::mqttbroker::lib::Mqtt::Mqtt ( const std::string & connectionName, const std::shared_ptr< iot::mqtt::server::broker::Broker > & broker, const nlohmann::json & mappingJson )

explicit

Definition at line 57 of file Mqtt.cpp.

        : iot::mqtt::server::Mqtt(connectionName, broker)
        , mqtt::lib::MqttMapper(mappingJson) {
    }

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

Here is the call graph for this function:

Member Function Documentation

onConnect()

void mqtt::mqttbroker::lib::Mqtt::onConnect ( const iot::mqtt::packets::Connect & connect )

finalprivate

Definition at line 64 of file Mqtt.cpp.

                                                                              {
        VLOG(1) << "MQTT: Connected";
 
        MqttModel::instance().addClient(clientId, this);
    }

References mqtt::mqttbroker::lib::MqttModel::addClient(), and mqtt::mqttbroker::lib::MqttModel::instance().

Here is the call graph for this function:

onDisconnected()

void mqtt::mqttbroker::lib::Mqtt::onDisconnected ( )

finalprivate

Definition at line 76 of file Mqtt.cpp.

                              {
        MqttModel::instance().delClient(clientId);
 
        VLOG(1) << "MQTT: Disconnected";
    }

References mqtt::mqttbroker::lib::MqttModel::delClient(), and mqtt::mqttbroker::lib::MqttModel::instance().

Here is the call graph for this function:

onPublish()

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

finalprivate

Definition at line 70 of file Mqtt.cpp.

                                                             {
        MqttModel::instance().publish(publish);
 
        publishMappings(publish);
    }

References mqtt::mqttbroker::lib::MqttModel::instance(), mqtt::mqttbroker::lib::MqttModel::publish(), and mqtt::lib::MqttMapper::publishMappings().

Here is the call graph for this function:

publishMapping()

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

finalprivatevirtual

Implements mqtt::lib::MqttMapper.

Definition at line 82 of file Mqtt.cpp.

                                                                                                        {
        broker->publish(clientId, topic, message, qoS, retain);
 
        publishMappings(iot::mqtt::packets::Publish(getPacketIdentifier(), topic, message, qoS, false, retain));
    }

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

Here is the call graph for this function:

---

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

• mqttbroker/lib/Mqtt.h
• mqttbroker/lib/Mqtt.cpp