Merge "Add a guard to break if no connection"
This commit is contained in:
commit
7d5d19aed6
|
@ -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))
|
||||
|
|
Loading…
Reference in New Issue