mqtt::mqttintegrator::websocket::SubProtocolFactory Class Reference

#include <SubProtocolFactory.h>

Inheritance diagram for mqtt::mqttintegrator::websocket::SubProtocolFactory:

Collaboration diagram for mqtt::mqttintegrator::websocket::SubProtocolFactory:

Public Member Functions
	SubProtocolFactory ()

Private Member Functions
iot::mqtt::client::SubProtocol *	create (web::websocket::SubProtocolContext *subProtocolContext) override

Detailed Description

Definition at line 54 of file SubProtocolFactory.h.

Constructor & Destructor Documentation

SubProtocolFactory()

mqtt::mqttintegrator::websocket::SubProtocolFactory::SubProtocolFactory ( )

explicit

Definition at line 62 of file SubProtocolFactory.cpp.

        : web::websocket::SubProtocolFactory<iot::mqtt::client::SubProtocol>::SubProtocolFactory(NAME) {
    }

Referenced by mqttClientSubProtocolFactory().

Here is the caller graph for this function:

Member Function Documentation

create()

iot::mqtt::client::SubProtocol * mqtt::mqttintegrator::websocket::SubProtocolFactory::create ( web::websocket::SubProtocolContext * subProtocolContext )

overrideprivate

Definition at line 66 of file SubProtocolFactory.cpp.

                                                                                                           {
        iot::mqtt::client::SubProtocol* subProtocol = nullptr;
 
        nlohmann::json& mappingJson =
            mqtt::lib::JsonMappingReader::readMappingFromFile(utils::Config::getStringOptionValue("--mqtt-mapping-file"));
 
        if (mappingJson.contains("connection")) {
            subProtocol = new iot::mqtt::client::SubProtocol(
                subProtocolContext,
                getName(),
                new mqtt::mqttintegrator::lib::Mqtt(subProtocolContext->getSocketConnection()->getConnectionName(),
                                                    mappingJson["connection"],
                                                    mappingJson["mapping"],
                                                    utils::Config::getStringOptionValue("--mqtt-session-store")));
        }
 
        return subProtocol;
    }

References mqtt::lib::JsonMappingReader::readMappingFromFile().

Here is the call graph for this function:

---

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

• mqttintegrator/websocket/SubProtocolFactory.h
• mqttintegrator/websocket/SubProtocolFactory.cpp