Mqtt: wait for retained messages

therealtimex · Dec 23, 2023 · 96ef894 · 96ef894
1 parent d10497f
commit 96ef894
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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
 	}
 }