vendor/shapecode/cron-bundle/src/EventListener/ServiceJobLoaderListener.php line 36

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Shapecode\Bundle\CronBundle\EventListener;
  7. use Shapecode\Bundle\CronBundle\Event\LoadJobsEvent;
  8. use Shapecode\Bundle\CronBundle\Model\CronJobMetadata;
  9. use Symfony\Component\Console\Command\Command;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. final class ServiceJobLoaderListener implements EventSubscriberInterface
  13. {
  14.     /** @var CronJobMetadata[] */
  15.     private $jobs = [];
  17.     public function addCommand(
  18.         string $expression,
  19.         Command $command,
  20.         ?string $arguments = null,
  21.         int $maxInstances = 1
  22.     ) : void {
  23.         $this->jobs[] = CronJobMetadata::createByCommand($expression, $command, $arguments, $maxInstances);
  24.     }
  26.     /**
  27.      * @inheritDoc
  28.      */
  29.     public static function getSubscribedEvents() : array
  30.     {
  31.         return [
  32.             LoadJobsEvent::NAME => 'onLoadJobs',
  33.         ];
  34.     }
  36.     public function onLoadJobs(LoadJobsEvent $event) : void
  37.     {
  38.         foreach ($this->jobs as $job) {
  39.             $event->addJob($job);
  40.         }
  41.     }
  42. }