adjusted downlink messge handler framework

2022-03-24 17:25:42 +08:00
parent 0ef02dcf4b
commit 3d34e57a4c
5 changed files with 11 additions and 4 deletions
--- a/src/IRbabyAlink.cpp
+++ b/src/IRbabyAlink.cpp
@@ -106,4 +106,7 @@ static void registerCallback(const char* topic, int qos) {

 static void irisAlinkCallback(const char *topic, uint8_t *data, int length) {
    INFOF("IRIS downstream message : topic = %s, length = %d, data = %s\n", topic, length, (char*) data);
+    if (NULL != g_downstream_topic.c_str() && 0 == strcmp(topic, g_downstream_topic.c_str())) {
+        handleIrisKitMessage((const char*) data, length);
+    }
 }