vendor/3slab/vdm-library-bundle/EventSubscriber/Monitoring/MonitoringWorkerStartedSubscriber.php line 65

Open in your IDE?
  1. <?php
  3. /**
  4.  * @package    3slab/VdmLibraryBundle
  5.  * @copyright  2020 Suez Smart Solutions 3S.lab
  6.  * @license    https://github.com/3slab/VdmLibraryBundle/blob/master/LICENSE
  7.  */
  9. namespace Vdm\Bundle\LibraryBundle\EventSubscriber\Monitoring;
  11. use Psr\Log\NullLogger;
  12. use Vdm\Bundle\LibraryBundle\Event\CollectWorkerStartedEvent;
  13. use Vdm\Bundle\LibraryBundle\Monitoring\Model\RunningStat;
  14. use Vdm\Bundle\LibraryBundle\Service\Monitoring\Monitoring;
  15. use Vdm\Bundle\LibraryBundle\Service\Monitoring\MonitoringService;
  16. use Vdm\Bundle\LibraryBundle\Service\Monitoring\Storage\StorageInterface;
  17. use Psr\Log\LoggerInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Messenger\Event\WorkerStartedEvent;
  21. /**
  22.  * Class MonitoringWorkerStartedSubscriber
  23.  *
  24.  * @package Vdm\Bundle\LibraryBundle\EventSubscriber\Monitoring
  25.  */
  26. class MonitoringWorkerStartedSubscriber implements EventSubscriberInterface
  27. {
  28.     /**
  29.      * @var MonitoringService
  30.      */
  31.     protected $monitoring;
  33.     /**
  34.      * @var LoggerInterface
  35.      */
  36.     protected $logger;
  38.     /**
  39.      * MonitoringWorkerHandledMessageListener constructor.
  40.      *
  41.      * @param MonitoringService $monitoring
  42.      * @param LoggerInterface|null $vdmLogger
  43.      */
  44.     public function __construct(MonitoringService $monitoring, LoggerInterface $vdmLogger = null)
  45.     {
  46.         $this->monitoring = $monitoring;
  47.         $this->logger = $vdmLogger ?? new NullLogger();
  48.     }
  50.     /**
  51.      * Method executed on WorkerStartedEvent event
  52.      *
  53.      * @param WorkerStartedEvent $event
  54.      */
  55.     public function onWorkerStartedEvent(WorkerStartedEvent $event)
  56.     {
  57.         $this->handleMonitoring();
  58.     }
  60.     /**
  61.      * Method executed on CollectWorkerStartedEvent event
  62.      *
  63.      * @param CollectWorkerStartedEvent $event
  64.      */
  65.     public function onCollectWorkerStartedEvent(CollectWorkerStartedEvent $event)
  66.     {
  67.         $this->handleMonitoring();
  68.     }
  70.     /**
  71.      * Set running stat
  72.      */
  73.     protected function handleMonitoring(): void
  74.     {
  75.         $this->monitoring->update(Monitoring::RUNNING_STAT, 1);
  76.         $this->logger->debug('worker started metric sent');
  77.     }
  79.     /**
  80.      * {@inheritDoc}
  81.      * @codeCoverageIgnore
  82.      */
  83.     public static function getSubscribedEvents(): array
  84.     {
  85.         return [
  86.             CollectWorkerStartedEvent::class => 'onCollectWorkerStartedEvent',
  87.             WorkerStartedEvent::class => 'onWorkerStartedEvent',
  88.         ];
  89.     }
  90. }