Permalink
Browse files

only ack message after all (postprocessing) work is done

  • Loading branch information...
1 parent 7de5947 commit ae689e9d8b9b72fac3f19cc67b6a311ef04dbec5 @bkw bkw committed Feb 6, 2014
Showing with 2 additions and 2 deletions.
  1. +2 −2 worker/worker.py
View
@@ -93,9 +93,9 @@ def _process(self, message):
raw, notif = views.process_raw_data(
self.deployment, args, asJson, self.exchange)
- self.processed += 1
- message.ack()
POST_PROCESS_METHODS[raw.get_name()](raw, notif)
+ message.ack()
+ self.processed += 1
self._check_memory()

0 comments on commit ae689e9

Please sign in to comment.