Congegni/sintonia
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

use AMQP heartbeat feature

Browse source
This commit is contained in:
Roberto Soto 2019-11-02 20:00:43 -07:00
parent 5b3c0cb1c8
commit 8a0f474075
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
python_apps/pypo/pypo/pypomessagehandler.py
View file

@ -48,8 +48,9 @@ class PypoMessageHandler(Thread):
schedule_queue = Queue("pypo-fetch", exchange=schedule_exchange, key="foo") schedule_queue = Queue("pypo-fetch", exchange=schedule_exchange, key="foo")
with Connection(self.config["host"], \ with Connection(self.config["host"], \
self.config["user"], \ self.config["user"], \
self.config["password"],\ self.config["password"], \
self.config["vhost"]) as connection: self.config["vhost"], \
hearbeat = 4) as connection:
rabbit = RabbitConsumer(connection, [schedule_queue], self) rabbit = RabbitConsumer(connection, [schedule_queue], self)
rabbit.run() rabbit.run()
except Exception, e: except Exception, e: