diff options
| author | David Hurst | 2017-09-18 10:36:08 -0600 |
|---|---|---|
| committer | GitHub | 2017-09-18 10:36:08 -0600 |
| commit | 5794862d2037138d6d8aacad0b5f6adafeb22193 (patch) | |
| tree | 5f7b019f2cae1a81e2ffa751958956b3bcdb3015 | |
| parent | 9f60b21dd37c35c0b7909b5f1d8e403ef761d513 (diff) | |
| parent | 4990de5e53026200d86cd59e0a94474f0e13f3aa (diff) | |
| download | eventmq-5794862d2037138d6d8aacad0b5f6adafeb22193.tar.gz eventmq-5794862d2037138d6d8aacad0b5f6adafeb22193.zip | |
Merge pull request #55 from eventmq/fix/metric_by_worker_typo
Fix typo in router for metrics gathering
| -rw-r--r-- | eventmq/router.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/eventmq/router.py b/eventmq/router.py index 7c221bc..c35e88c 100644 --- a/eventmq/router.py +++ b/eventmq/router.py | |||
| @@ -502,7 +502,7 @@ class Router(HeartbeatMixin): | |||
| 502 | else: | 502 | else: |
| 503 | self.processed_message_counts[queue_name] += 1 | 503 | self.processed_message_counts[queue_name] += 1 |
| 504 | 504 | ||
| 505 | if queue_name not in self.processed_message_counts_by_worker: | 505 | if worker_addr not in self.processed_message_counts_by_worker: |
| 506 | self.processed_message_counts_by_worker[worker_addr] = 1 | 506 | self.processed_message_counts_by_worker[worker_addr] = 1 |
| 507 | else: | 507 | else: |
| 508 | self.processed_message_counts_by_worker[worker_addr] += 1 | 508 | self.processed_message_counts_by_worker[worker_addr] += 1 |