src/App/Subscriber/Scheduler/AbstractSchedulerSubscriber.php line 47

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Scheduler;
  5. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  6. use Platform\QueueBundle\Event\AsyncEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. /**
  10.  *
  11.  */
  12. abstract class AbstractSchedulerSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * All extending classes need to set this value to something unique.
  16.      * It is the name of the event to watch for that is going to be injected into the MQ by the Lambda functions.
  17.      */
  18.     public const EVENT = null;
  20.     /**
  21.      * @var EntityManager
  22.      */
  23.     protected EntityManager $em;
  25.     /**
  26.      * {@inheritDoc}
  27.      */
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return static::EVENT ? [
  31.             static::EVENT => ['onEvent', 0],
  32.         ] : [];
  33.     }
  35.     /**
  36.      * @param EntityManager $em
  37.      */
  38.     public function __construct(EntityManager $em)
  39.     {
  40.         $this->em = $em;
  41.     }
  43.     /**
  44.      * @param AsyncEvent $event
  45.      * @return void
  46.      */
  47.     public function onEvent(AsyncEvent $event): void
  48.     {
  49.         if ( ! static::EVENT) {
  50.             return;
  51.         }
  52.         try {
  53.             $this->handleEvent($event);
  54.         } catch (\Exception $e) {
  55.             // TODO: an error happened, need to log it somewhere eventually...
  56.         }
  57.     }
  59.     /**
  60.      * @param AsyncEvent $event
  61.      * @return void
  62.      */
  63.     abstract protected function handleEvent(AsyncEvent $event): void;
  64. }