mqtt::mqttbroker::lib Namespace Reference

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

Functions
void	to_json (nlohmann::json &j, const MqttModel::MqttModelEntry &mqttModelEntry)
void	to_json (nlohmann::json &j, const subscribe &subscribe)
void	to_json (nlohmann::json &j, const unsubscribe &unsubscribe)
void	to_json (nlohmann::json &j, const retaine &retaine)
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 MqttModel::MqttModelEntry &	mqttModelEntry )

Definition at line 99 of file MqttModel.cpp.

                                                                                 {
        const Mqtt* mqtt = mqttModelEntry.getMqtt();
        const core::socket::stream::SocketConnection* socketConnection = mqtt->getMqttContext()->getSocketConnection();
 
        j = {{"clientId", mqtt->getClientId()},
             {"since", mqttModelEntry.onlineSince()},
             {"duration", mqttModelEntry.onlineDuration()},
             {"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()},
             {"localAddress", socketConnection->getLocalAddress().toString()},
             {"remoteAddress", socketConnection->getRemoteAddress().toString()}};
    }

to_json() [2/5]

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

Definition at line 159 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 )

Definition at line 151 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 )

Definition at line 132 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 )

Definition at line 141 of file MqttModel.cpp.

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

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