src/EventSubscriber/FailedMessageSubscriber.php line 31

  1. <?php
  3. namespace App\EventSubscriber;
  6. use Psr\Log\LoggerInterface;
  7. use Symfony\Bridge\Twig\Mime\TemplatedEmail;
  8. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\Mailer\MailerInterface;
  11. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  12. use Symfony\Component\Mime\Address;
  14. class FailedMessageSubscriber implements EventSubscriberInterface
  15. {
  16.     private MailerInterface $mailer;
  17.     private ParameterBagInterface $params;
  18.     public function __construct( MailerInterface $mailerInterface, LoggerInterface $logger, ParameterBagInterface $params)
  19.     {
  20.         $this->mailer = $mailerInterface;        
  21.         $this->params = $params;
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [            
  27.             WorkerMessageFailedEvent::class => 'onMessageFailed'
  28.         ];
  29.     }
  31.     public function onMessageFailed( WorkerMessageFailedEvent $event): void {
  32.          $error = $event->getThrowable()->getMessage();
  33.          $trace = $event->getThrowable()->getTraceAsString();
  34.          $emailFrom = $this->params->get('app.email_from');
  35.          $emailTo = $this->params->get('app.email_administrateur');
  37.          $email = (new TemplatedEmail())
  38.          ->from(new Address($emailFrom, 'Valoire-Estel KAT'))
  39.          ->to($emailTo)
  40.          ->subject('An error has been occured')
  41.          ->htmlTemplate('emails/errors/error.html.twig')
  42.          ->context([
  43.              'error' => [
  44.                 'date' => date('Y-m-d H:i:m',strtotime('now') ),
  45.                 'context' => 'Message queue',
  46.                 'message' => $error,
  47.                 'trace' => $trace
  48.              ],
  49.          ]); 
  50.          $this->mailer->send($email);  
  51.     }
  53. }