monitoring

Author: ASKozienko

pkg/monitoring/ClientMonitoringExtension.php

@@ -39,6 +39,7 @@ public function onPostSend(PostSend $context): void
         $stats = new SentMessageStats(
             $timestampMs,
             $destination,
+            $context->getTransportDestination() instanceof Topic,
             $context->getTransportMessage()->getMessageId(),
             $context->getTransportMessage()->getCorrelationId(),
             $context->getTransportMessage()->getHeaders(),

pkg/monitoring/InfluxDbStorage.php

@@ -141,7 +141,7 @@ public function pushConsumedMessageStats(ConsumedMessageStats $stats): void
     public function pushSentMessageStats(SentMessageStats $stats): void
     {
         $tags = [
-            'queue' => $stats->getQueue(),
+            'destination' => $stats->getDestination(),
         ];
 
         $properties = $stats->getProperties();

pkg/monitoring/SentMessageStats.php

@@ -24,7 +24,12 @@ class SentMessageStats implements Stats
     /**
      * @var string
      */
-    protected $queue;
+    protected $destination;
+
+    /**
+     * @var bool
+     */
+    protected $isTopic;
 
     /**
      * @var array
@@ -38,14 +43,16 @@ class SentMessageStats implements Stats
 
     public function __construct(
         int $timestampMs,
-        string $queue,
+        string $destination,
+        bool $isTopic,
         ?string $messageId,
         ?string $correlationId,
         array $headers,
         array $properties
     ) {
         $this->timestampMs = $timestampMs;
-        $this->queue = $queue;
+        $this->destination = $destination;
+        $this->isTopic = $isTopic;
         $this->messageId = $messageId;
         $this->correlationId = $correlationId;
         $this->headers = $headers;
@@ -57,9 +64,14 @@ public function getTimestampMs(): int
         return $this->timestampMs;
     }
 
-    public function getQueue(): string
+    public function getDestination(): string
+    {
+        return $this->destination;
+    }
+
+    public function isTopic(): bool
     {
-        return $this->queue;
+        return $this->isTopic;
     }
 
     public function getMessageId(): ?string