simon987/chan_feed
1
0
Fork 0
mirror of https://github.com/simon987/chan_feed.git synced 2025-04-18 01:36:44 +00:00
Code Issues Projects Releases Wiki Activity

hotfix

Browse Source
This commit is contained in:
simon 2019-09-05 19:45:03 -04:00
parent 547933cfd9
commit fa32408b15
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
run.py
View File

@ -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: