758 if (unit->event_msg) { |
758 if (unit->event_msg) { |
759 payload = xstrcat(payload, (char *)",\"event\":\""); |
759 payload = xstrcat(payload, (char *)",\"event\":\""); |
760 payload = xstrcat(payload, unit->event_msg); |
760 payload = xstrcat(payload, unit->event_msg); |
761 payload = xstrcat(payload, (char *)"\""); |
761 payload = xstrcat(payload, (char *)"\""); |
762 } |
762 } |
763 payload = xstrcat(payload, (char *)"}}"); |
763 payload = xstrcat(payload, (char *)",\"fermenter_uuid\":\""); |
|
764 payload = xstrcat(payload, unit->uuid); |
|
765 payload = xstrcat(payload, (char *)"\"}}"); |
764 |
766 |
765 topic = xstrcat(topic_base((char *)"DLOG"), (char *)"/"); |
767 topic = xstrcat(topic_base((char *)"DLOG"), (char *)"/"); |
766 topic = xstrcat(topic, unit->alias); |
768 topic = xstrcat(topic, unit->alias); |
767 publisher(mosq, topic, payload, true); |
769 publisher(mosq, topic, payload, true); |
768 printf("%s\n", payload); |
770 printf("%s\n", payload); |