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)
void	subscribe (const std::string &topic, uint8_t qoS)
void	unsubscribe (const std::string &topic)
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	onSubscribe (const iot::mqtt::packets::Subscribe &subscribe) final
void	onUnsubscribe (const iot::mqtt::packets::Unsubscribe &unsubscribe) 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 60 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 79 of file Mqtt.cpp.

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

References mqtt::mqttbroker::lib::MqttModel::connectClient(), 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 109 of file Mqtt.cpp.

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

References mqtt::mqttbroker::lib::MqttModel::disconnectClient(), 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 85 of file Mqtt.cpp.

                                                             {
        VLOG(1) << "MQTT: Publish";
 
        MqttModel::instance().publishMessage(publish.getTopic(), publish.getMessage(), publish.getQoS(), publish.getRetain());
 
        publishMappings(publish);
    }

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

Here is the call graph for this function:

onSubscribe()

void mqtt::mqttbroker::lib::Mqtt::onSubscribe ( const iot::mqtt::packets::Subscribe & subscribe )

finalprivate

Definition at line 93 of file Mqtt.cpp.

                                                                   {
        VLOG(1) << "MQTT: Subscribe";
 
        for (const iot::mqtt::Topic& topic : subscribe.getTopics()) {
            MqttModel::instance().subscribeClient(clientId, topic.getName(), topic.getQoS());
        }
    }

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

Referenced by subscribe().

Here is the call graph for this function:

Here is the caller graph for this function:

onUnsubscribe()

void mqtt::mqttbroker::lib::Mqtt::onUnsubscribe ( const iot::mqtt::packets::Unsubscribe & unsubscribe )

finalprivate

Definition at line 101 of file Mqtt.cpp.

                                                                         {
        VLOG(1) << "MQTT: Unsubscribe";
 
        for (const std::string& topic : unsubscribe.getTopics()) {
            MqttModel::instance().unsubscribeClient(clientId, topic);
        }
    }

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

Referenced by unsubscribe().

Here is the call graph for this function:

Here is the caller 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 115 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:

subscribe()

void mqtt::mqttbroker::lib::Mqtt::subscribe	(	const std::string &	topic,
		uint8_t	qoS )

Definition at line 67 of file Mqtt.cpp.

                                                            {
        broker->subscribe(clientId, topic, qoS);
 
        onSubscribe(iot::mqtt::packets::Subscribe(0, {{topic, qoS}}));
    }

References onSubscribe().

Here is the call graph for this function:

unsubscribe()

void mqtt::mqttbroker::lib::Mqtt::unsubscribe

(

const std::string &

topic

)

Definition at line 73 of file Mqtt.cpp.

                                                 {
        broker->unsubscribe(clientId, topic);
 
        onUnsubscribe(iot::mqtt::packets::Unsubscribe(0, {{topic, 0}}));
    }

References onUnsubscribe().

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