thermferm/mqtt.c

changeset 555
c6f04bfcec2c
parent 554
ab9f22ab57b5
child 557
ae17042a6d39
equal deleted inserted replaced
554:ab9f22ab57b5 555:c6f04bfcec2c
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);

mercurial