diff options
Diffstat (limited to 'rmq.py')
-rw-r--r-- | rmq.py | 2 |
1 files changed, 0 insertions, 2 deletions
@@ -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) |