From 4762a852d81c7312dadd1948adb286c012455eb6 Mon Sep 17 00:00:00 2001 From: Fabian Schlenz Date: Wed, 29 Apr 2020 20:25:41 +0200 Subject: [PATCH] MQTT messages can now be retained. --- include/my_mqtt.h | 4 ++-- src/mqtt.cpp | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/include/my_mqtt.h b/include/my_mqtt.h index 0d4503c..6169c80 100644 --- a/include/my_mqtt.h +++ b/include/my_mqtt.h @@ -17,8 +17,8 @@ void mqtt_setup(); void mqtt_loop(); -void mqtt_publish(const char* topic, int number); -void mqtt_publish(const char* topic, const char* message); +void mqtt_publish(const char* topic, int number, bool retain=false); +void mqtt_publish(const char* topic, const char* message, bool retain=false); void mqtt_log(const char* message); void mqtt_log(int number); diff --git a/src/mqtt.cpp b/src/mqtt.cpp index f3561fd..97a20fd 100644 --- a/src/mqtt.cpp +++ b/src/mqtt.cpp @@ -133,16 +133,16 @@ void mqtt_loop() { String mqtt_log_str = String(); -void mqtt_publish(const char* topic, int number) { +void mqtt_publish(const char* topic, int number, bool retain) { char b[32]; sprintf(b, "%d", number); - mqtt_publish(topic, b); + mqtt_publish(topic, b, retain); } -void mqtt_publish(const char* topic, const char* message) { +void mqtt_publish(const char* topic, const char* message, bool retain) { char t[127]; sprintf(t, MQTT_TOPIC "%s", topic); - mqtt_client.publish(t, message); + mqtt_client.publish(t, message, retain); } void mqtt_log(const char* message) {