bmsd/mqtt.c

changeset 567
6bf0afc33e70
parent 502
a8a6901b5a99
child 572
7a03181d29a3
--- a/bmsd/mqtt.c	Tue Dec 10 20:13:00 2019 +0100
+++ b/bmsd/mqtt.c	Fri Dec 13 16:49:50 2019 +0100
@@ -26,6 +26,7 @@
 #include "nodes.h"
 #include "fermenters.h"
 #include "co2meters.h"
+#include "ispindels.h"
 
 
 extern sys_config       Config;
@@ -179,6 +180,9 @@
             co2meter_log(message->topic, (char *)message->payload);
             return;
         }
+	if (strstr(message->topic, (char *)"ispindel")) {
+	    ispindel_mqtt(message->topic, (char *)message->payload);
+	}
 	syslog(LOG_NOTICE, "MQTT: message callback %s :: %d", message->topic, message->payloadlen);
     } else {
 	if (strstr(message->topic, (char *)"NBIRTH")) {

mercurial