Skip to content

Commit 8660953

Browse files
committed
avoid clearing out retained messages
1 parent 861a0df commit 8660953

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

functions/daemon.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -473,7 +473,7 @@ func setupMQTTSingleton(server *config.Server, publishOnly bool) error {
473473
func setHostSubscription(client mqtt.Client, server string) {
474474
hostID := config.Netclient().ID
475475
slog.Info("subscribing to host updates for", "host", hostID, "server", server)
476-
clearRetainedMsg(client, fmt.Sprintf("peers/host/%s/%s", hostID.String(), server))
476+
//clearRetainedMsg(client, fmt.Sprintf("peers/host/%s/%s", hostID.String(), server))
477477
if token := client.Subscribe(fmt.Sprintf("peers/host/%s/%s", hostID.String(), server), 0, mqtt.MessageHandler(HostPeerUpdate)); token.Wait() && token.Error() != nil {
478478
slog.Error("unable to subscribe to host peer updates", "host", hostID, "server", server, "error", token.Error())
479479
return

0 commit comments

Comments
 (0)