src/EventSubscriber/MessengerWorkerRunningSubscriber.php line 15

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Symfony\Component\Messenger\Event\WorkerRunningEvent;
  8. class MessengerWorkerRunningSubscriber implements EventSubscriberInterface
  9. {
  10.     /**
  11.      * @param WorkerRunningEvent $event
  12.      *
  13.      * @return void
  14.      */
  15.     public function onWorkerRunning(WorkerRunningEvent $event): void
  16.     {
  17.         if ($event->isWorkerIdle()) {
  18.             $event->getWorker()->stop();
  19.         }
  20.     }
  22.     /**
  23.      * @return array<string>
  24.      */
  25.     public static function getSubscribedEvents()
  26.     {
  27.         return [
  28.             WorkerRunningEvent::class => 'onWorkerRunning',
  29.         ];
  30.     }
  31. }