iot::mqtt::server::broker::Session Class Reference

#include <Session.h>

Inheritance diagram for iot::mqtt::server::broker::Session:

Collaboration diagram for iot::mqtt::server::broker::Session:

Public Member Functions
	Session ()=default
	Session (iot::mqtt::server::Mqtt *mqtt)
void	sendPublish (iot::mqtt::server::broker::Message &message, uint8_t qoS, bool retain)
void	publishQueued ()
Session *	renew (iot::mqtt::server::Mqtt *mqtt)
void	retain ()
bool	isActive () const
bool	isOwnedBy (const iot::mqtt::server::Mqtt *mqtt) const
nlohmann::json	toJson () const final
void	fromJson (const nlohmann::json &json)
Public Member Functions inherited from iot::mqtt::Session
	Session ()=default
	Session (const nlohmann::json &json)
virtual	~Session ()=default
	Session (const Session &)=default
Session &	operator= (const Session &)=default
bool	isCleanSession () const
void	fromJson (const nlohmann::json &json)
void	clear ()

Private Attributes
iot::mqtt::server::Mqtt *	mqtt = nullptr
std::deque< Message >	messageQueue

Detailed Description

Definition at line 40 of file Session.h.

Constructor & Destructor Documentation

Session() [1/2]

iot::mqtt::server::broker::Session::Session ( )

default

Session() [2/2]

iot::mqtt::server::broker::Session::Session ( iot::mqtt::server::Mqtt * mqtt )

explicit

Definition at line 40 of file Session.cpp.

        : mqtt(mqtt) {
    }

Member Function Documentation

fromJson()

void iot::mqtt::server::broker::Session::fromJson

(

const nlohmann::json &

json

)

Definition at line 109 of file Session.cpp.

                                                   {
        std::transform(json["message_queue"].begin(),
                       json["message_queue"].end(),
                       std::back_inserter(messageQueue),
                       [](const nlohmann::json& jsonMessage) {
                           return Message().fromJson(jsonMessage);
                       });
 
        iot::mqtt::Session::fromJson(json);
    }

isActive()

bool iot::mqtt::server::broker::Session::isActive

(

)

const

Definition at line 91 of file Session.cpp.

                                 {
        return mqtt != nullptr;
    }

Referenced by sendPublish().

Here is the caller graph for this function:

isOwnedBy()

bool iot::mqtt::server::broker::Session::isOwnedBy

(

const iot::mqtt::server::Mqtt *

mqtt

)

const

Definition at line 95 of file Session.cpp.

                                                               {
        return this->mqtt == mqtt;
    }

publishQueued()

void iot::mqtt::server::broker::Session::publishQueued

(

)

Definition at line 71 of file Session.cpp.

                                {
        LOG(INFO) << "MQTT Broker:     send queued messages ...";
        for (iot::mqtt::server::broker::Message& message : messageQueue) {
            sendPublish(message, message.getQoS(), false);
        }
        LOG(INFO) << "MQTT Broker:     ... done";
 
        messageQueue.clear();
    }

renew()

Session * iot::mqtt::server::broker::Session::renew

(

iot::mqtt::server::Mqtt *

mqtt

)

Definition at line 81 of file Session.cpp.

                                                   {
        this->mqtt = mqtt;
 
        return this;
    }

retain()

void iot::mqtt::server::broker::Session::retain

(

)

Definition at line 87 of file Session.cpp.

                         {
        this->mqtt = nullptr;
    }

sendPublish()

void iot::mqtt::server::broker::Session::sendPublish	(	iot::mqtt::server::broker::Message &	message,
		uint8_t	qoS,
		bool	retain )

Definition at line 44 of file Session.cpp.

                                                                        {
        LOG(INFO) << "MQTT Broker:   TopicName: " << message.getTopic();
        LOG(INFO) << "MQTT Broker:   Message:\n" << iot::mqtt::Mqtt::toHexString(message.getMessage());
        LOG(DEBUG) << "MQTT Broker:   QoS: " << static_cast<uint16_t>(std::min(qoS, message.getQoS()));
 
        if (isActive()) {
            LOG(DEBUG) << "MQTT Broker:   ClientId: " << mqtt->getClientId();
            LOG(DEBUG) << "MQTT Broker:   OriginClientId: " << message.getOriginClientId();
 
            if ((mqtt->getReflect() || mqtt->getClientId() != message.getOriginClientId())) {
                mqtt->sendPublish(message.getTopic(),
                                  message.getMessage(),
                                  std::min(message.getQoS(), qoS),
                                  !mqtt->getReflect() ? message.getOriginRetain() || retain : retain);
            } else {
                LOG(INFO) << "MQTT Broker:     Suppress reflection to origin to avoid message looping";
            }
        } else {
            if (message.getQoS() == 0) {
                messageQueue.clear();
            }
 
            message.setQoS(std::min(message.getQoS(), qoS));
            messageQueue.emplace_back(message);
        }
    }

References iot::mqtt::server::broker::Message::getOriginRetain(), iot::mqtt::server::broker::Message::getQoS(), iot::mqtt::server::Mqtt::getReflect(), isActive(), and iot::mqtt::server::broker::Message::setQoS().

Here is the call graph for this function:

toJson()

nlohmann::json iot::mqtt::server::broker::Session::toJson ( ) const

finalvirtual

Reimplemented from iot::mqtt::Session.

Definition at line 99 of file Session.cpp.

                                       {
        nlohmann::json json = iot::mqtt::Session::toJson();
 
        std::transform(messageQueue.begin(), messageQueue.end(), std::back_inserter(json["message_queue"]), [](const Message& message) {
            return message.toJson();
        });
 
        return json;
    }

Member Data Documentation

messageQueue

std::deque<Message> iot::mqtt::server::broker::Session::messageQueue

private

Definition at line 62 of file Session.h.

mqtt

iot::mqtt::server::Mqtt* iot::mqtt::server::broker::Session::mqtt = nullptr

private

Definition at line 60 of file Session.h.

---

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

• iot/mqtt/server/broker/Session.h
• iot/mqtt/server/broker/Session.cpp