vendor/symfony/messenger/EventListener/SendFailedMessageToFailureTransportListener.php line 40

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Messenger\EventListener;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\ErrorHandler\Exception\FlattenException;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  18. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  19. use Symfony\Component\Messenger\Stamp\DelayStamp;
  20. use Symfony\Component\Messenger\Stamp\RedeliveryStamp;
  21. use Symfony\Component\Messenger\Stamp\SentToFailureTransportStamp;
  22. use Symfony\Component\Messenger\Transport\Sender\SenderInterface;
  24. /**
  25.  * Sends a rejected message to a "failure transport".
  26.  *
  27.  * @author Ryan Weaver <ryan@symfonycasts.com>
  28.  */
  29. class SendFailedMessageToFailureTransportListener implements EventSubscriberInterface
  30. {
  31.     private $failureSender;
  32.     private $logger;
  34.     public function __construct(SenderInterface $failureSender, LoggerInterface $logger = null)
  35.     {
  36.         $this->failureSender = $failureSender;
  37.         $this->logger = $logger;
  38.     }
  40.     public function onMessageFailed(WorkerMessageFailedEvent $event)
  41.     {
  42.         if ($event->willRetry()) {
  43.             return;
  44.         }
  46.         $envelope = $event->getEnvelope();
  48.         // avoid re-sending to the failed sender
  49.         if (null !== $envelope->last(SentToFailureTransportStamp::class)) {
  50.             return;
  51.         }
  53.         $throwable = $event->getThrowable();
  54.         if ($throwable instanceof HandlerFailedException) {
  55.             $throwable = $throwable->getNestedExceptions()[0];
  56.         }
  58.         $flattenedException = class_exists(FlattenException::class) ? FlattenException::createFromThrowable($throwable) : null;
  59.         $envelope = $envelope->with(
  60.             new SentToFailureTransportStamp($event->getReceiverName()),
  61.             new DelayStamp(0),
  62.             new RedeliveryStamp(0, $throwable->getMessage(), $flattenedException)
  63.         );
  65.         if (null !== $this->logger) {
  66.             $this->logger->info('Rejected message {class} will be sent to the failure transport {transport}.', [
  67.                 'class' => \get_class($envelope->getMessage()),
  68.                 'transport' => \get_class($this->failureSender),
  69.             ]);
  70.         }
  72.         $this->failureSender->send($envelope);
  73.     }
  75.     public static function getSubscribedEvents()
  76.     {
  77.         return [
  78.             WorkerMessageFailedEvent::class => ['onMessageFailed', -100],
  79.         ];
  80.     }
  81. }