fix global topic reduction
This commit is contained in:
@@ -1021,8 +1021,7 @@ MqttHandler::MqttHandler(UserInfo* userInfo, BusHandler* busHandler, MessageMap*
|
|||||||
if (m_globalTopic.has("circuit")) {
|
if (m_globalTopic.has("circuit")) {
|
||||||
map<string, string> values;
|
map<string, string> values;
|
||||||
values["circuit"] = "global";
|
values["circuit"] = "global";
|
||||||
string result;
|
m_globalTopic.compress(values);
|
||||||
m_globalTopic.reduce(values, result);
|
|
||||||
}
|
}
|
||||||
m_subscribeTopic = getTopic(nullptr, "#");
|
m_subscribeTopic = getTopic(nullptr, "#");
|
||||||
if (check(mosquitto_lib_init(), "unable to initialize")) {
|
if (check(mosquitto_lib_init(), "unable to initialize")) {
|
||||||
|
|||||||
Reference in New Issue
Block a user