src/Listener/WorkerMessageFailedListener.php line 15

Open in your IDE?
  1. <?php
  3. namespace App\Listener;
  5. use App\Message\EmailNotification;
  6. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  7. use Symfony\Component\Messenger\MessageBusInterface;
  9. class WorkerMessageFailedListener
  10. {
  11.     public function __construct(private  MessageBusInterface $bus)
  12.     {
  13.     }
  15.     public function __invoke(WorkerMessageFailedEvent $event): void
  16.     {
  17.         if(!$event->willRetry()){
  18.             $this->bus->dispatch(new EmailNotification(
  19.                 ['subject' => 'Worker Message Failed', 'content' => $event->getThrowable()->getMessage()]
  20.             ));
  21.         }
  22.     }
  23. }