Merge pull request #10 from mundschenk-at/retain-discovery

Retain discovery topics
erkexzcx · Jan 13, 2024 · ffbedf5 · ffbedf5
2 parents 16dea51 + 8fc5310
commit ffbedf5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/mqtt/producer.go b/pkg/mqtt/producer.go
@@ -99,7 +99,7 @@ func produceAnnounceMapTopic(client mqttgo.Client, rmt string, c *config.MQTTCon
 		panic(err)
 	}
 
-	token := client.Publish(announceTopic, 1, false, announcementData)
+	token := client.Publish(announceTopic, 1, true, announcementData)
 	token.Wait()
 	if token.Error() != nil {
 		log.Printf("[MQTT producer] Failed to publish: %v\n", token.Error())
@@ -135,7 +135,7 @@ func producerAnnounceCalibrationTopic(client mqttgo.Client, cdt string, c *confi
 		panic(err)
 	}
 
-	token := client.Publish(announceTopic, 1, false, announcementData)
+	token := client.Publish(announceTopic, 1, true, announcementData)
 	token.Wait()
 	if token.Error() != nil {
 		log.Printf("[MQTT producer] Failed to publish: %v\n", token.Error())