src/EventsSubscriber/Worker/WorkerFailedMessageSubscriber.php line 33

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventsSubscriber\Worker;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  10. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  12. /**
  13.  * Fail loud. Logs every message failure with its REAL exception class, and in particular every
  14.  * message that exhausts its retries and is routed to the `failed` dead-letter queue.
  15.  *
  16.  * This is the single, structured, greppable signal that work was dropped — the counterpart to the
  17.  * CloudWatch DLQ-depth alarm. It replaces the previous pattern of swallowed exceptions and
  18.  * unwatched logs: a dropped payout, email, or video check is now an ERROR line carrying the message
  19.  * class, transport, and underlying error, not silence.
  20.  *
  21.  * It logs to the dedicated `dlq` channel, which is shipped to stderr -> CloudWatch (the log
  22.  * counterpart to the DLQ-depth alarm) but excluded from the Sentry handler: exhausted-retry churn is
  23.  * expected, high-volume and 0-user-impact, so it must not consume Sentry quota. The underlying
  24.  * handler exceptions still reach Sentry on their own via the messenger integration — this is only the
  25.  * summary signal line, so dropping it from Sentry loses no diagnostic detail.
  26.  */
  27. class WorkerFailedMessageSubscriber implements EventSubscriberInterface
  28. {
  29.     public function __construct(private readonly LoggerInterface $dlqLogger)
  30.     {
  31.     }
  33.     public function onMessageFailed(WorkerMessageFailedEvent $event): void
  34.     {
  35.         $throwable = $event->getThrowable();
  37.         // Messenger wraps handler exceptions in HandlerFailedException — unwrap to the real cause so
  38.         // the log (and Sentry grouping) reflect the actual error, not the generic wrapper.
  39.         $cause = $throwable instanceof HandlerFailedException
  40.             ? ($throwable->getPrevious() ?? $throwable)
  41.             : $throwable;
  43.         $context = [
  44.             'message' => $event->getEnvelope()->getMessage()::class,
  45.             'transport' => $event->getReceiverName(),
  46.             'exception' => $cause::class,
  47.             'error' => $cause->getMessage(),
  48.             'willRetry' => $event->willRetry(),
  49.         ];
  51.         if ($event->willRetry()) {
  52.             $this->dlqLogger->warning('Messenger message failed; will retry', $context);
  54.             return;
  55.         }
  57.         $this->dlqLogger->error('Messenger message exhausted retries; routed to dead-letter (DLQ)', $context);
  58.     }
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             WorkerMessageFailedEvent::class => 'onMessageFailed',
  64.         ];
  65.     }
  66. }