iot/sprocket-plugin-mqtt
1
0
Fork 0
mirror of https://gitlab.com/wirelos/sprocket-plugin-mqtt.git synced 2025-12-16 06:24:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

set subscribed flag

Browse Source
This commit is contained in:
0x1d
2018-11-16 01:16:50 +01:00
parent 0a5bfc8cf9
commit cbba58095c
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/MqttPlugin.cpp
View File

@@ -35,18 +35,19 @@ void MqttPlugin::connect()
if (client->connect(mqttConfig.clientName)) if (client->connect(mqttConfig.clientName))
{ {
// bind handlers to all local subscriptions // bind handlers to all local subscriptions
if (!locallySubscribed)
{
for (auto const &localSub : mediator->subscriptions) for (auto const &localSub : mediator->subscriptions)
{ {
// bind all local topics to the MQTT upstream once // bind all local topics to the MQTT upstream once
if (!locallySubscribed)
{
subscribe(localSub.first.c_str(), bind(&MqttPlugin::upstreamHandler, this, localSub.first.c_str(), _1)); subscribe(localSub.first.c_str(), bind(&MqttPlugin::upstreamHandler, this, localSub.first.c_str(), _1));
}
// subscribe topic on remote queue to dispatch messages to local subscriptions // subscribe topic on remote queue to dispatch messages to local subscriptions
client->subscribe( client->subscribe(
(String(mqttConfig.inTopicRoot) + String(localSub.first.c_str())) (String(mqttConfig.inTopicRoot) + String(localSub.first.c_str()))
.c_str()); .c_str());
} }
locallySubscribed = true;
}
PRINT_MSG(Serial, "MQTT", "connected"); PRINT_MSG(Serial, "MQTT", "connected");
} }
} }