diff options
author | 2019-03-24 17:35:43 -0600 | |
---|---|---|
committer | 2019-03-24 17:35:43 -0600 | |
commit | 1f49e3edd7a1167eb81438c57dc1dd3789bb0b3b (patch) | |
tree | b71e0889a4ea6ed8d22852b9805bd13a60994f00 /rmq.py | |
parent | Cleanup imports and RMQ (diff) |
More formatting fixes
Diffstat (limited to 'rmq.py')
-rw-r--r-- | rmq.py | 1 |
1 files changed, 1 insertions, 0 deletions
@@ -25,6 +25,7 @@ class Rmq: def consume(self, queue=QUEUE, callback=None, thread_ws=None, run_once=False): """Subscribe to read from a RMQ channel.""" + while True: try: connection = pika.BlockingConnection(self.con_params) |