2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef APPS_MQTTBROKER_MQTTINTEGRATOR_SOCKETCONTEXT_H
43#define APPS_MQTTBROKER_MQTTINTEGRATOR_SOCKETCONTEXT_H
45#include "lib/MqttMapper.h"
47#include <iot/mqtt/client/Mqtt.h>
49#ifndef DOXYGEN_SHOULD_SKIP_THIS
56namespace mqtt::mqttintegrator::
lib {
59 :
public iot::
mqtt::client::Mqtt
62 explicit Mqtt(
const std::string& connectionName,
63 const nlohmann::json& connectionJson,
65 const std::string& sessionStoreFileName);
71 [[nodiscard]]
bool onSignal(
int signum)
final;
76 void publishMapping(
const std::string& topic,
const std::string& message, uint8_t qoS,
bool retain)
final;
void publishMappings(const iot::mqtt::packets::Publish &publish)
MqttMapper(const nlohmann::json &mappingJson)
std::list< iot::mqtt::Topic > extractSubscriptions()
void publishMapping(const std::string &topic, const std::string &message, uint8_t qoS, bool retain) final
void onPublish(const iot::mqtt::packets::Publish &publish) final
void onConnack(const iot::mqtt::packets::Connack &connack) final
const nlohmann::json & connectionJson
Mqtt(const std::string &connectionName, const nlohmann::json &connectionJson, const nlohmann::json &mappingJson, const std::string &sessionStoreFileName)
bool onSignal(int signum) final
iot::mqtt::client::Mqtt Super