equal
deleted
inserted
replaced
32 |
32 |
33 class MQTTCommand { |
33 class MQTTCommand { |
34 private: |
34 private: |
35 std::wstring_convert<codecvt_utf8<wchar_t>> convertor; // TODO: support also other encodings. |
35 std::wstring_convert<codecvt_utf8<wchar_t>> convertor; // TODO: support also other encodings. |
36 std::atomic<bool> continueProcessing{true}; |
36 std::atomic<bool> continueProcessing{true}; |
|
37 static void parseConnectionString(const std::string& connectionString, std::string& hostname, int& port); |
|
38 static void check(std::string operation, int result); |
37 public: |
39 public: |
38 virtual ~MQTTCommand(); |
40 virtual ~MQTTCommand(); |
39 |
41 |
40 void process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration); |
42 void process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration); |
41 |
43 |