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) {