src/App/Subscriber/Async/AbstractAsyncSubscriber.php line 49

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Async;
  5. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  6. use Platform\QueueBundle\Event\AsyncEvent;
  7. use Platform\QueueBundle\Model\AsyncMessage;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. abstract class AbstractAsyncSubscriber implements EventSubscriberInterface
  11. {
  12.     /**
  13.      * All extending classes need to set this value to something unique.
  14.      */
  15.     public const EVENT = null;
  17.     /**
  18.      * The default priority to use for items of this type.
  19.      */
  20.     public const DEFAULT_PRIORITY = null;
  22.     /**
  23.      * @var EntityManager
  24.      */
  25.     protected EntityManager $em;
  27.     /**
  28.      * {@inheritDoc}
  29.      */
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return static::EVENT ? [
  33.             static::EVENT => ['onEvent', 0],
  34.         ] : [];
  35.     }
  37.     /**
  38.      * @param EntityManager $em
  39.      */
  40.     public function __construct(EntityManager $em)
  41.     {
  42.         $this->em = $em;
  43.     }
  45.     /**
  46.      * @param AsyncEvent $event
  47.      * @return void
  48.      */
  49.     public function onEvent(AsyncEvent $event): void
  50.     {
  51.         if ( ! static::EVENT) {
  52.             return;
  53.         }
  54.         try {
  55.             $this->handleEvent($event);
  56.         } catch (\Exception $e) {
  57.             // TODO: an error happened, need to log it somewhere eventually...
  58.         }
  59.     }
  61.     /**
  62.      * @param AsyncEvent $event
  63.      * @return void
  64.      */
  65.     abstract protected function handleEvent(AsyncEvent $event): void;
  66. }