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 } }