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

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