From 8bc5033d7f65fc00b741f1ed10f445a229b6ad1c Mon Sep 17 00:00:00 2001 From: Serg Melikyan Date: Wed, 13 Mar 2013 17:58:42 +0400 Subject: [PATCH] Fix issue with ack on results --- portas/portas/common/service.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/portas/portas/common/service.py b/portas/portas/common/service.py index 49fe664..143a358 100644 --- a/portas/portas/common/service.py +++ b/portas/portas/common/service.py @@ -42,7 +42,7 @@ class TaskResultHandlerService(service.Service): bind(conf.results_exchange, conf.results_queue) bind(conf.reports_exchange, conf.reports_queue) - ch.basic_consume(conf.results_exchange, callback=handle_result, no_ack=True) + ch.basic_consume(conf.results_exchange, callback=handle_result) ch.basic_consume(conf.reports_exchange, callback=handle_report, no_ack=True) while ch.callbacks: ch.wait()