Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improve example code

This commit is contained in:
Ask Solem 2011-09-12 12:57:12 +01:00
parent 5f267314bf
commit aceaa71956
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
examples/simple_task_queue/worker.py
View File

@ -32,4 +32,7 @@ if __name__ == "__main__":
setup_logging(loglevel="INFO")
with BrokerConnection("amqp://guest:guest@localhost:5672//") as conn:
Worker(conn).run()
try:
Worker(conn).run()
except KeyboardInterrupt:
print("bye bye")