From 3a146c286344474bd5d6958b3c2eab10341ff399 Mon Sep 17 00:00:00 2001 From: sco1 Date: Wed, 24 Apr 2019 17:25:47 -0400 Subject: Relint Snekbox with new linting rules --- rmq.py | 2 -- 1 file changed, 2 deletions(-) (limited to 'rmq.py') diff --git a/rmq.py b/rmq.py index 919ef19..29fc448 100644 --- a/rmq.py +++ b/rmq.py @@ -25,7 +25,6 @@ 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) @@ -72,7 +71,6 @@ class Rmq: def publish(self, message, queue=QUEUE, routingkey=ROUTING_KEY, exchange=EXCHANGE): """Open a connection to publish (write) to a RMQ channel.""" - try: connection = pika.BlockingConnection(self.con_params) -- cgit v1.2.3