src/EventSubscriber/FailedMessageSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Message\ExportMessage;
  6. use App\Service\MailerService;
  7. use Exception;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  11. use Symfony\Component\Messenger\Event\WorkerStoppedEvent;
  12. use Vdm\Bundle\LibraryBundle\Service\StopWorkerService;
  14. class FailedMessageSubscriber implements EventSubscriberInterface
  15. {
  16.     private LoggerInterface $logger;
  17.     private MailerService $mailerService;
  18.     private StopWorkerService $stopWorkerService;
  20.     public function __construct(
  21.         LoggerInterface $logger,
  22.         MailerService $mailerService,
  23.         StopWorkerService $stopWorkerService
  24.     ) {
  25.         $this->logger = $logger;
  26.         $this->mailerService = $mailerService;
  27.         $this->stopWorkerService = $stopWorkerService;
  28.     }
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             WorkerMessageFailedEvent::class => ['onWorkerMessageFailed', 1],
  34.             WorkerStoppedEvent::class => ['onWorkerStoppedEvent', 1],
  35.         ];
  36.     }
  38.     public function onWorkerMessageFailed(WorkerMessageFailedEvent $event): void
  39.     {
  40.         $message = $event->getEnvelope()->getMessage();
  41.         if ($event->willRetry()) {
  42.             $this->logger->info(sprintf(
  43.                 'Message "%s" will be retried, skipping sending error message.',
  44.                 get_class($message)
  45.             ));
  47.             return;
  48.         }
  50.         switch (true) {
  51.             case $message instanceof ExportMessage:
  52.                 $this->onExportMessageFailed($message);
  53.                 break;
  54.         }
  55.     }
  57.     public function onWorkerStoppedEvent(WorkerStoppedEvent $event): void
  58.     {
  59.         // Avoid to break consumer in RethrowExceptionAfterWorkerStoppedSubscriber
  60.         $this->stopWorkerService->setThrowable(null);
  61.     }
  63.     private function onExportMessageFailed(ExportMessage $message): void
  64.     {
  65.         $this->logger->info('==SendingErrorEmail==============================================');
  66.         $this->logger->info('Export message failed after all retries, sending error email to user ' . $message->getUser()->getUsername(), [$message]);
  68.         try {
  69.             //$this->mailerService->sendExportErrorEmail($message->getUser());
  70.         } catch (Exception $e) {
  71.             $this->logger->critical("Critical error when process ERROR email message : " . $e->getMessage(), [$message]);
  72.         }
  73.     }
  74. }