Merge pull request #18 from FranMoraton/add-retry-count

add retry count to logger
PcComponentes · Nov 25, 2021 · 501b6b4 · 501b6b4
2 parents 19f71c7 + 7accbca
commit 501b6b4
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/src/MessageLogger/MessageLoggerMiddleware.php b/src/MessageLogger/MessageLoggerMiddleware.php
@@ -8,6 +8,7 @@
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
 use Symfony\Component\Messenger\Middleware\StackInterface;
+use Symfony\Component\Messenger\Stamp\RedeliveryStamp;
 
 final class MessageLoggerMiddleware implements MiddlewareInterface
 {
@@ -26,6 +27,7 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope
         $context = [
             'message' => $message,
             'name' => $message::messageName(),
+            'retry_count' => $this->extractEnvelopeRetryCount($envelope),
         ];
 
         try {
@@ -51,4 +53,11 @@ private function messageFromEnvelope(Envelope $envelope): Message
     {
         return $envelope->getMessage();
     }
+
+    private function extractEnvelopeRetryCount(Envelope $envelope): int
+    {
+        $retryCountStamp = $envelope->last(RedeliveryStamp::class);
+
+        return null !== $retryCountStamp ? $retryCountStamp->getRetryCount() : 0;
+    }
 }
diff --git a/src/Util/Filebeat/template.json b/src/Util/Filebeat/template.json
@@ -52,6 +52,9 @@
           "message": {
             "type": "text"
           },
+          "retry_count": {
+            "type": "integer"
+          },
           "name": {
             "type": "text",
             "fields": {