aboutsummaryrefslogtreecommitdiffstats
path: root/rmq.py
diff options
context:
space:
mode:
authorGravatar Christopher Goes <[email protected]>2019-03-24 17:35:43 -0600
committerGravatar Christopher Goes <[email protected]>2019-03-24 17:35:43 -0600
commit1f49e3edd7a1167eb81438c57dc1dd3789bb0b3b (patch)
treeb71e0889a4ea6ed8d22852b9805bd13a60994f00 /rmq.py
parentCleanup imports and RMQ (diff)
More formatting fixes
Diffstat (limited to 'rmq.py')
-rw-r--r--rmq.py1
1 files changed, 1 insertions, 0 deletions
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)