From 52785f37b1eb52380e57b31655103dbd06a5df81 Mon Sep 17 00:00:00 2001
From: rschoene <rene.schoene@tu-dresden.de>
Date: Mon, 29 Jun 2020 14:51:59 +0200
Subject: [PATCH] Use retain for initial robot config.
- see #26
---
src/main/resources/MqttUpdater.jadd | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/src/main/resources/MqttUpdater.jadd b/src/main/resources/MqttUpdater.jadd
index 394735c..df1dc10 100644
--- a/src/main/resources/MqttUpdater.jadd
+++ b/src/main/resources/MqttUpdater.jadd
@@ -231,8 +231,16 @@ public class MqttUpdater {
}
public void publish(String topic, byte[] bytes) {
+ publish(topic, bytes, false);
+ }
+
+ public void publish(String topic, byte[] bytes, boolean retain) {
+ publish(topic, bytes, this.qos, retain);
+ }
+
+ public void publish(String topic, byte[] bytes, org.fusesource.mqtt.client.QoS qos, boolean retain) {
connection.getDispatchQueue().execute(() -> {
- connection.publish(topic, bytes, qos, false, new org.fusesource.mqtt.client.Callback<Void>() {
+ connection.publish(topic, bytes, qos, retain, new org.fusesource.mqtt.client.Callback<Void>() {
@Override
public void onSuccess(Void value) {
logger.debug("Published some bytes to {}", topic);
--
GitLab