Merge pull request #849 from mariusbalcytis/master

Send topic and command for consumed messages
php-enqueue · May 16, 2019 · 0c9f7c4 · 0c9f7c4
2 parents 446eb40 + c4b9cb2
commit 0c9f7c4
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/pkg/monitoring/InfluxDbStorage.php b/pkg/monitoring/InfluxDbStorage.php
@@ -160,6 +160,16 @@ public function pushConsumedMessageStats(ConsumedMessageStats $stats): void
             'status' => $stats->getStatus(),
         ];
 
+        $properties = $stats->getProperties();
+
+        if (false === empty($properties[Config::TOPIC])) {
+            $tags['topic'] = $properties[Config::TOPIC];
+        }
+
+        if (false === empty($properties[Config::COMMAND])) {
+            $tags['command'] = $properties[Config::COMMAND];
+        }
+
         $values = [
             'receivedAt' => $stats->getReceivedAtMs(),
             'processedAt' => $stats->getTimestampMs(),