MQTTSuite
Loading...
Searching...
No Matches
mqtt::bridge::SocketContextFactory Class Reference

#include <SocketContextFactory.h>

Inheritance diagram for mqtt::bridge::SocketContextFactory:
Collaboration diagram for mqtt::bridge::SocketContextFactory:

Public Member Functions

core::socket::stream::SocketContext * create (core::socket::stream::SocketConnection *socketConnection) final

Detailed Description

Definition at line 53 of file SocketContextFactory.h.

Member Function Documentation

◆ create()

core::socket::stream::SocketContext * mqtt::bridge::SocketContextFactory::create ( core::socket::stream::SocketConnection * socketConnection)
final

Definition at line 61 of file SocketContextFactory.cpp.

61 {
62 iot::mqtt::SocketContext* socketContext = nullptr;
63
64 mqtt::bridge::lib::Broker* broker = mqtt::bridge::lib::BridgeStore::instance().getBroker(socketConnection->getInstanceName());
65
66 if (broker != nullptr) {
67 VLOG(1) << " Creating Broker instance '" << broker->getName() << "' of Bridge '" << broker->getBridge().getName() << "'";
68 VLOG(1) << " Bridge client id : " << broker->getClientId();
69 VLOG(1) << " Transport: " << broker->getTransport();
70 VLOG(1) << " Protocol: " << broker->getProtocol();
71 VLOG(1) << " Encryption: " << broker->getEncryption();
72
73 VLOG(1) << " Topics:";
74 const std::list<iot::mqtt::Topic>& topics = broker->getTopics();
75 for (const iot::mqtt::Topic& topic : topics) {
76 VLOG(1) << " " << static_cast<uint16_t>(topic.getQoS()) << ":" << topic.getName();
77 }
78
79 socketContext =
80 new iot::mqtt::SocketContext(socketConnection, new mqtt::bridge::lib::Mqtt(socketConnection->getConnectionName(), *broker));
81 }
82
83 return socketContext;
84 }
Broker * getBroker(const std::string &fullInstanceName)
static BridgeStore & instance()
const std::string & getName() const
Definition Bridge.cpp:67
const std::string & getName() const
Definition Broker.cpp:142
const std::list< iot::mqtt::Topic > & getTopics() const
Definition Broker.cpp:166
const std::string & getClientId() const
Definition Broker.cpp:102
const std::string & getEncryption() const
Definition Broker.cpp:150
const std::string & getProtocol() const
Definition Broker.cpp:146
const std::string & getTransport() const
Definition Broker.cpp:154
Bridge & getBridge() const
Definition Broker.cpp:94

References mqtt::bridge::lib::Broker::getBridge(), mqtt::bridge::lib::BridgeStore::getBroker(), mqtt::bridge::lib::Broker::getClientId(), mqtt::bridge::lib::Broker::getEncryption(), mqtt::bridge::lib::Bridge::getName(), mqtt::bridge::lib::Broker::getName(), mqtt::bridge::lib::Broker::getProtocol(), mqtt::bridge::lib::Broker::getTopics(), mqtt::bridge::lib::Broker::getTransport(), mqtt::bridge::lib::BridgeStore::instance(), and mqtt::bridge::lib::Mqtt::Mqtt().

Here is the call graph for this function:

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