mqtt::mqttbroker::lib Namespace Reference

Classes
struct	subscribe
struct	unsubscribe
struct	retaine
struct	release
class	Mqtt
class	MqttModel

Functions
static void	to_json (nlohmann::json &j, const Mqtt *mqtt)
static void	to_json (nlohmann::json &j, const subscribe &subscribe)
static void	to_json (nlohmann::json &j, const unsubscribe &unsubscribe)
static void	to_json (nlohmann::json &j, const retaine &retaine)
static void	to_json (nlohmann::json &j, const release &release)

Function Documentation

to_json() [1/5]

void mqtt::mqttbroker::lib::to_json ( nlohmann::json & j, const Mqtt * mqtt )

static

Definition at line 97 of file MqttModel.cpp.

                                                           {
        j = {{"clientId", mqtt->getClientId()},
             {"connectionName", mqtt->getConnectionName()},
             {"cleanSession", mqtt->getCleanSession()},
             {"connectFlags", mqtt->getConnectFlags()},
             {"username", mqtt->getUsername()},
             {"usernameFlag", mqtt->getUsernameFlag()},
             {"password", mqtt->getPassword()},
             {"passwordFlag", mqtt->getPasswordFlag()},
             {"keepAlive", mqtt->getKeepAlive()},
             {"protocol", mqtt->getProtocol()},
             {"protocolLevel", mqtt->getLevel()},
             {"loopPrevention", !mqtt->getReflect()},
             {"willMessage", mqtt->getWillMessage()},
             {"willTopic", mqtt->getWillTopic()},
             {"willQoS", mqtt->getWillQoS()},
             {"willFlag", mqtt->getWillFlag()},
             {"willRetain", mqtt->getWillRetain()},
             {"since", mqtt->getMqttContext()->getSocketConnection()->getSocketContext()->getOnlineSince()},
             {"duration", mqtt->getMqttContext()->getSocketConnection()->getSocketContext()->getOnlineDuration()},
             {"localAddress", mqtt->getMqttContext()->getSocketConnection()->getLocalAddress().toString()},
             {"remoteAddress", mqtt->getMqttContext()->getSocketConnection()->getRemoteAddress().toString()}};
    }

to_json() [2/5]

void mqtt::mqttbroker::lib::to_json ( nlohmann::json & j, const release & release )

static

Definition at line 154 of file MqttModel.cpp.

                                                                 {
        j = {{"topic", release.topic}};
    }

References mqtt::mqttbroker::lib::release::topic.

to_json() [3/5]

void mqtt::mqttbroker::lib::to_json ( nlohmann::json & j, const retaine & retaine )

static

Definition at line 146 of file MqttModel.cpp.

                                                                 {
        j = {{"topic", retaine.topic}, {"message", retaine.message}, {"qos", retaine.qoS}};
    }

References mqtt::mqttbroker::lib::retaine::message, mqtt::mqttbroker::lib::retaine::qoS, and mqtt::mqttbroker::lib::retaine::topic.

to_json() [4/5]

void mqtt::mqttbroker::lib::to_json ( nlohmann::json & j, const subscribe & subscribe )

static

Definition at line 127 of file MqttModel.cpp.

                                                                     {
        j = {{"clientId", subscribe.clientId}, {"topic", subscribe.topic}, {"qos", subscribe.qoS}};
    }

References mqtt::mqttbroker::lib::subscribe::clientId, mqtt::mqttbroker::lib::subscribe::qoS, and mqtt::mqttbroker::lib::subscribe::topic.

to_json() [5/5]

void mqtt::mqttbroker::lib::to_json ( nlohmann::json & j, const unsubscribe & unsubscribe )

static

Definition at line 136 of file MqttModel.cpp.

                                                                         {
        j = {{"clientId", unsubscribe.clientId}, {"topic", unsubscribe.topic}};
    }

References mqtt::mqttbroker::lib::unsubscribe::clientId, and mqtt::mqttbroker::lib::unsubscribe::topic.