From 1f49e3edd7a1167eb81438c57dc1dd3789bb0b3b Mon Sep 17 00:00:00 2001 From: Christopher Goes Date: Sun, 24 Mar 2019 17:35:43 -0600 Subject: More formatting fixes --- rmq.py | 1 + 1 file changed, 1 insertion(+) (limited to 'rmq.py') diff --git a/rmq.py b/rmq.py index b4cb90a..919ef19 100644 --- a/rmq.py +++ b/rmq.py @@ -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) -- cgit v1.2.3