src/Event/CronRunningEvent.php line 19

Open in your IDE?
  1. <?php
  4. namespace App\Event;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\Messenger\Event\WorkerRunningEvent;
  9. /**
  10.  * Class ExtractFailedEvent
  11.  *  
  12.  * Required to call a Cron job:
  13.  * * * * * * bin/console messenger:consume lectures failed --memory-limit=128M --time-limit=3600
  14.  * 
  15.  * Used to avoid to install the Supervisor in the server and create a config file for each project/queue
  16.  */
  17. class CronRunningEvent implements EventSubscriberInterface
  18. {
  19.     public function onWorkerRunning(WorkerRunningEvent $event): void
  20.     {
  21.         // Returns true when no message has been received by the worker.
  22.         // If no message has been received , we stop the worker
  23.         if ($event->isWorkerIdle()){
  24.             $event->getWorker()->stop();
  25.         }
  26.     }
  28.     /**
  29.      * @return array<string>
  30.      */
  31.     public static function getSubscribedEvents()
  32.     {
  33.         return [
  34.             WorkerRunningEvent::class => 'onWorkerRunning',
  35.         ];
  36.     }
  37. }