diff --git a/tripleoclient/plugin.py b/tripleoclient/plugin.py index bb05c9fef..b8571d782 100644 --- a/tripleoclient/plugin.py +++ b/tripleoclient/plugin.py @@ -138,6 +138,9 @@ class WebsocketClient(object): messages. """ + if not self._ws.connected: + return + if timeout is None: LOG.warning("Waiting for messages on queue '{}' with no timeout." .format(self._queue_name))