Merge "Add a guard to break if no connection"

This commit is contained in:
Zuul 2018-09-21 16:45:59 +00:00 committed by Gerrit Code Review
commit 7d5d19aed6
1 changed files with 3 additions and 0 deletions

View File

@ -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))