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

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\Container\ContainerInterface;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  18. use Symfony\Component\Messenger\Stamp\DelayStamp;
  19. use Symfony\Component\Messenger\Stamp\RedeliveryStamp;
  20. use Symfony\Component\Messenger\Stamp\SentToFailureTransportStamp;
  22. /**
  23.  * Sends a rejected message to a "failure transport".
  24.  *
  25.  * @author Ryan Weaver <ryan@symfonycasts.com>
  26.  */
  27. class SendFailedMessageToFailureTransportListener implements EventSubscriberInterface
  28. {
  29.     private $failureSenders;
  30.     private $logger;
  32.     public function __construct(ContainerInterface $failureSenders, LoggerInterface $logger = null)
  33.     {
  34.         $this->failureSenders = $failureSenders;
  35.         $this->logger = $logger;
  36.     }
  38.     public function onMessageFailed(WorkerMessageFailedEvent $event)
  39.     {
  40.         if ($event->willRetry()) {
  41.             return;
  42.         }
  44.         if (!$this->failureSenders->has($event->getReceiverName())) {
  45.             return;
  46.         }
  48.         $failureSender = $this->failureSenders->get($event->getReceiverName());
  50.         $envelope = $event->getEnvelope();
  52.         // avoid re-sending to the failed sender
  53.         if (null !== $envelope->last(SentToFailureTransportStamp::class)) {
  54.             return;
  55.         }
  57.         $envelope = $envelope->with(
  58.             new SentToFailureTransportStamp($event->getReceiverName()),
  59.             new DelayStamp(0),
  60.             new RedeliveryStamp(0)
  61.         );
  63.         if (null !== $this->logger) {
  64.             $this->logger->info('Rejected message {class} will be sent to the failure transport {transport}.', [
  65.                 'class' => \get_class($envelope->getMessage()),
  66.                 'transport' => \get_class($failureSender),
  67.             ]);
  68.         }
  70.         $failureSender->send($envelope);
  71.     }
  73.     public static function getSubscribedEvents(): array
  74.     {
  75.         return [
  76.             WorkerMessageFailedEvent::class => ['onMessageFailed', -100],
  77.         ];
  78.     }
  79. }