From 96ef894ccce60aab0b20a40186542ba4e8bbf29e Mon Sep 17 00:00:00 2001
From: andig <cpuidle@gmx.de>
Date: Sat, 23 Dec 2023 14:01:53 +0100
Subject: [PATCH] Mqtt: wait for retained messages

---
 provider/mqtt/client.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/provider/mqtt/client.go b/provider/mqtt/client.go
index e59324643..2aeb7568e 100644
--- a/provider/mqtt/client.go
+++ b/provider/mqtt/client.go
@@ -141,6 +141,8 @@ func (m *Client) Listen(topic string, callback func(string)) error {
 	case <-time.After(request.Timeout):
 		return fmt.Errorf("subscribe: %s: %w", topic, api.ErrTimeout)
 	case <-token.Done():
+		// TODO depends on https://github.com/eclipse/paho.mqtt.golang/issues/663
+		time.Sleep(100 * time.Millisecond)
 		return nil
 	}
 }