src/EventSubscriber/FailedMessageSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Event\UpdateOrganizationEvent;
  6. use App\Message\ExportMessage;
  7. use App\Service\MailerService;
  8. use Exception;
  9. use Psr\Log\LoggerInterface;
  10. use Symfony\Component\EventDispatcher\Attribute\AsEventListener;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  13. use Symfony\Component\Messenger\Event\WorkerStoppedEvent;
  14. use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
  15. use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
  17. class FailedMessageSubscriber implements EventSubscriberInterface
  18. {
  19.     private LoggerInterface $logger;
  20.     private MailerService $mailerService;
  22.     public function __construct(
  23.         LoggerInterface $logger,
  24.         MailerService $mailerService
  25.     ) {
  26.         $this->logger = $logger;
  27.         $this->mailerService = $mailerService;
  28.     }
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             WorkerMessageFailedEvent::class => ['onWorkerMessageFailed', 1],
  34.         ];
  35.     }
  37.     public function onWorkerMessageFailed(WorkerMessageFailedEvent $event): void
  38.     {
  39.         $message = $event->getEnvelope()->getMessage();
  40.         if ($event->willRetry()) {
  41.             $this->logger->info(sprintf(
  42.                 'Message "%s" will be retried, skipping processing error message',
  43.                 get_class($message)
  44.             ));
  46.             return;
  47.         }
  49.         switch (true) {
  50.             case $message instanceof ExportMessage:
  51.                 $this->onExportMessageFailed($message);
  52.                 break;
  53.         }
  54.     }
  56.     private function onExportMessageFailed(ExportMessage $message): void
  57.     {
  58.         $this->logger->info('==ProcessingErrorMessage==============================================');
  59.         $this->logger->info('Export message failed after all retries, sending error email to user ' . $message->getUser()->getUsername(), [$message]);
  61.         try {
  62.             $this->mailerService->sendExportErrorEmail($message->getUser());
  63.         } catch (Exception $e) {
  64.             $this->logger->critical("Critical error when process ERROR email message : " . $e->getMessage(), [$message]);
  65.         }
  66.     }
  67. }