comparison: bmsd/mqtt.c
bmsd/mqtt.c
- changeset 567
- 6bf0afc33e70
- parent 502
- a8a6901b5a99
- child 572
- 7a03181d29a3
equal
deleted
inserted
replaced
| 566:e526dc911bc1 | 567:6bf0afc33e70 |
|---|---|
| 24 #include "xutil.h" | 24 #include "xutil.h" |
| 25 #include "mqtt.h" | 25 #include "mqtt.h" |
| 26 #include "nodes.h" | 26 #include "nodes.h" |
| 27 #include "fermenters.h" | 27 #include "fermenters.h" |
| 28 #include "co2meters.h" | 28 #include "co2meters.h" |
| 29 #include "ispindels.h" | |
| 29 | 30 |
| 30 | 31 |
| 31 extern sys_config Config; | 32 extern sys_config Config; |
| 32 extern int debug; | 33 extern int debug; |
| 33 | 34 |
| 177 } | 178 } |
| 178 if (strstr(message->topic, (char *)"co2meters") && strstr(message->topic, (char *)"DLOG")) { | 179 if (strstr(message->topic, (char *)"co2meters") && strstr(message->topic, (char *)"DLOG")) { |
| 179 co2meter_log(message->topic, (char *)message->payload); | 180 co2meter_log(message->topic, (char *)message->payload); |
| 180 return; | 181 return; |
| 181 } | 182 } |
| 183 if (strstr(message->topic, (char *)"ispindel")) { | |
| 184 ispindel_mqtt(message->topic, (char *)message->payload); | |
| 185 } | |
| 182 syslog(LOG_NOTICE, "MQTT: message callback %s :: %d", message->topic, message->payloadlen); | 186 syslog(LOG_NOTICE, "MQTT: message callback %s :: %d", message->topic, message->payloadlen); |
| 183 } else { | 187 } else { |
| 184 if (strstr(message->topic, (char *)"NBIRTH")) { | 188 if (strstr(message->topic, (char *)"NBIRTH")) { |
| 185 // Ignore ?? | 189 // Ignore ?? |
| 186 fprintf(stdout, "MQTT: %s NULL\n", message->topic); | 190 fprintf(stdout, "MQTT: %s NULL\n", message->topic); |
