Update router.py

eventmq · Aug 22, 2017 · 4990de5 · 4990de5
1 parent 9f60b21
commit 4990de5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/eventmq/router.py b/eventmq/router.py
@@ -502,7 +502,7 @@ def on_request(self, sender, msgid, msg, depth=1):
             else:
                 self.processed_message_counts[queue_name] += 1
 
-            if queue_name not in self.processed_message_counts_by_worker:
+            if worker_addr not in self.processed_message_counts_by_worker:
                 self.processed_message_counts_by_worker[worker_addr] = 1
             else:
                 self.processed_message_counts_by_worker[worker_addr] += 1