custom/plugins/PickwareErpStarter/src/MessageQueueMonitoring/WorkerRunningLogger.php line 36

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) Pickware GmbH. All rights reserved.
  4.  * This file is part of software that is released under a proprietary license.
  5.  * You must not copy, modify, distribute, make publicly available, or execute
  6.  * its contents or parts thereof without express permission by the copyright
  7.  * holder, unless otherwise permitted by law.
  8.  */
  10. declare(strict_types=1);
  12. namespace Pickware\PickwareErpStarter\MessageQueueMonitoring;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\Messenger\Event\WorkerRunningEvent;
  17. class WorkerRunningLogger implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var MessageQueueMonitoringService
  21.      */
  22.     private $messageQueueMonitoringService;
  24.     public function __construct(MessageQueueMonitoringService $messageQueueMonitoringService)
  25.     {
  26.         $this->messageQueueMonitoringService = $messageQueueMonitoringService;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             WorkerRunningEvent::class => 'logWorkerRunningEvent',
  33.         ];
  34.     }
  36.     public function logWorkerRunningEvent(WorkerRunningEvent $workerRunningEvent): void
  37.     {
  38.         $this->messageQueueMonitoringService->logCLIWorkerRun();
  39.     }
  40. }