equal
deleted
inserted
replaced
27 namespace mqtt { |
27 namespace mqtt { |
28 |
28 |
29 class Configuration { |
29 class Configuration { |
30 public: |
30 public: |
31 |
31 |
|
32 class ConnectionOption { |
|
33 public: |
|
34 relpipe::common::type::StringX name; |
|
35 relpipe::common::type::StringX value; |
|
36 |
|
37 ConnectionOption() = default; |
|
38 |
|
39 ConnectionOption(relpipe::common::type::StringX name, relpipe::common::type::StringX value) : name(name), value(value) { |
|
40 } |
|
41 |
|
42 |
|
43 }; |
|
44 |
32 relpipe::common::type::Integer messageCount = 1; |
45 relpipe::common::type::Integer messageCount = 1; |
33 relpipe::common::type::StringX relation = L"message"; |
46 relpipe::common::type::StringX relation = L"message"; |
34 relpipe::common::type::StringX stream = L"relpipe"; |
47 relpipe::common::type::StringX stream = L"relpipe"; |
35 |
48 relpipe::common::type::StringX connectionString = L"mqtt://localhost:1883"; |
|
49 std::vector<ConnectionOption> connectionOptions; |
|
50 |
36 virtual ~Configuration() { |
51 virtual ~Configuration() { |
37 } |
52 } |
38 }; |
53 }; |
39 |
54 |
40 } |
55 } |