jeans/openHASP
jeans/openHASP
1
0
Fork 0
mirror of https://github.com/HASwitchPlate/openHASP.git synced 2025-07-28 13:46:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Subcribe to group topics in native app

Browse Source
This commit is contained in:
fvanroie 2021-04-25 04:46:02 +02:00
parent c582df6550
commit 6520b001c3
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mqtt/hasp_mqtt_paho_single.cpp
View File

@ -84,7 +84,7 @@ bool mqttHAautodiscover = true;
#define MQTT_NODENAME ""; #define MQTT_NODENAME "";
#endif #endif
#ifndef MQTT_GROUPNAME #ifndef MQTT_GROUPNAME
#define MQTT_GROUPNAME ""; #define MQTT_GROUPNAME "plates";
#endif #endif
#ifndef MQTT_PREFIX #ifndef MQTT_PREFIX
@ -258,14 +258,19 @@ static void onConnect(void* context)
{ {
MQTTClient client = (MQTTClient)context; MQTTClient client = (MQTTClient)context;
connected = 1; connected = 1;
std::string topic;
LOG_VERBOSE(TAG_MQTT, "Successful connection"); LOG_VERBOSE(TAG_MQTT, "Successful connection");
std::string topic; topic = mqttGroupTopic + "command/#";
mqtt_subscribe(mqtt_client, topic.c_str());
topic = mqttNodeTopic + "command/#"; topic = mqttNodeTopic + "command/#";
mqtt_subscribe(mqtt_client, topic.c_str()); mqtt_subscribe(mqtt_client, topic.c_str());
topic = mqttGroupTopic + "config/#";
mqtt_subscribe(mqtt_client, topic.c_str());
topic = mqttNodeTopic + "config/#"; topic = mqttNodeTopic + "config/#";
mqtt_subscribe(mqtt_client, topic.c_str()); mqtt_subscribe(mqtt_client, topic.c_str());