From fa32408b151ae52f8339d53815c4525e2be70196 Mon Sep 17 00:00:00 2001 From: simon Date: Thu, 5 Sep 2019 19:45:03 -0400 Subject: [PATCH] hotfix --- run.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/run.py b/run.py index 8dc83b8..95e1208 100644 --- a/run.py +++ b/run.py @@ -179,6 +179,14 @@ def publish(item, board, helper): except Exception as e: logger.debug(traceback.format_exc()) logger.error(str(e)) + connect() + + +def connect(): + global chan_channel + rabbit = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_host)) + chan_channel = rabbit.channel() + chan_channel.exchange_declare(exchange="chan", exchange_type="topic") if __name__ == "__main__": @@ -199,9 +207,7 @@ if __name__ == "__main__": publish_thread = Thread(target=publish_worker, args=(publish_q, chan_helper)) publish_thread.start() - rabbit = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_host)) - chan_channel = rabbit.channel() - chan_channel.exchange_declare(exchange="chan", exchange_type="topic") + connect() s = ChanScanner(chan_helper) while True: