body property added for sent and consumed message stats

ClientMonitoringExtension.php

@@ -43,7 +43,8 @@ public function onPostSend(PostSend $context): void
             $context->getTransportMessage()->getMessageId(),
             $context->getTransportMessage()->getCorrelationId(),
             $context->getTransportMessage()->getHeaders(),
-            $context->getTransportMessage()->getProperties()
+            $context->getTransportMessage()->getProperties(),
+            $context->getTransportMessage()->getBody()
         );
 
         $this->safeCall(function () use ($stats) {

ConsumedMessageStats.php

@@ -51,6 +51,11 @@ class ConsumedMessageStats implements Stats
      */
     protected $properties;
 
+    /**
+     * @var string
+     */
+    protected $body;
+
     /**
      * @var bool;
      */
@@ -100,6 +105,7 @@ public function __construct(
         ?string $correlationId,
         array $headers,
         array $properties,
+        string $body,
         bool $redelivered,
         string $status,
         string $errorClass = null,
@@ -117,6 +123,7 @@ public function __construct(
         $this->correlationId = $correlationId;
         $this->headers = $headers;
         $this->properties = $properties;
+        $this->body = $body;
         $this->redelivered = $redelivered;
         $this->status = $status;
 
@@ -168,6 +175,11 @@ public function getProperties(): array
         return $this->properties;
     }
 
+    public function getBody(): string
+    {
+        return $this->body;
+    }
+
     public function isRedelivered(): bool
     {
         return $this->redelivered;

ConsumerMonitoringExtension.php

@@ -174,6 +174,7 @@ public function onProcessorException(ProcessorException $context): void
             $context->getMessage()->getCorrelationId(),
             $context->getMessage()->getHeaders(),
             $context->getMessage()->getProperties(),
+            $context->getMessage()->getBody(),
             $context->getMessage()->isRedelivered(),
             ConsumedMessageStats::STATUS_FAILED,
             get_class($context->getException()),
@@ -256,6 +257,7 @@ public function onResult(MessageResult $context): void
             $context->getMessage()->getCorrelationId(),
             $context->getMessage()->getHeaders(),
             $context->getMessage()->getProperties(),
+            $context->getMessage()->getBody(),
             $context->getMessage()->isRedelivered(),
             $status
         );

SentMessageStats.php

@@ -41,14 +41,20 @@ class SentMessageStats implements Stats
      */
     protected $properties;
 
+    /**
+     * @var string
+     */
+    protected $body;
+
     public function __construct(
         int $timestampMs,
         string $destination,
         bool $isTopic,
         ?string $messageId,
         ?string $correlationId,
         array $headers,
-        array $properties
+        array $properties,
+        string $body
     ) {
         $this->timestampMs = $timestampMs;
         $this->destination = $destination;
@@ -57,6 +63,7 @@ public function __construct(
         $this->correlationId = $correlationId;
         $this->headers = $headers;
         $this->properties = $properties;
+        $this->body = $body;
     }
 
     public function getTimestampMs(): int
@@ -93,4 +100,9 @@ public function getProperties(): array
     {
         return $this->properties;
     }
+
+    public function getBody(): string
+    {
+        return $this->body;
+    }
 }