monitoring

Author: ASKozienko

InfluxDbStorage.php

@@ -139,7 +139,10 @@ public function pushConsumedMessageStats(ConsumedMessageStats $stats): void
 
     public function pushSentMessageStats(SentMessageStats $stats): void
     {
-        $tags = [];
+        $tags = [
+            'queue' => $stats->getQueue(),
+        ];
+
         $properties = $stats->getProperties();
 
         if (false === empty($properties[Config::TOPIC])) {

SentMessageStats.php

@@ -11,6 +11,11 @@ class SentMessageStats implements Stats
      */
     protected $timestampMs;
 
+    /**
+     * @var string
+     */
+    protected $queue;
+
     /**
      * @var array
      */
@@ -23,10 +28,12 @@ class SentMessageStats implements Stats
 
     public function __construct(
         int $timestampMs,
+        string $queue,
         array $headers,
         array $properties
     ) {
         $this->timestampMs = $timestampMs;
+        $this->queue = $queue;
         $this->headers = $headers;
         $this->properties = $properties;
     }
@@ -36,6 +43,11 @@ public function getTimestampMs(): int
         return $this->timestampMs;
     }
 
+    public function getQueue(): string
+    {
+        return $this->queue;
+    }
+
     public function getHeaders(): array
     {
         return $this->headers;