src/Messenger/EventListener/WorkersRegistryEventListener.php line 44

Open in your IDE?
  1. <?php
  3. /**
  4.  * Copyright (c) 2011-present Qualiteam software Ltd. All rights reserved.
  5.  * See https://www.x-cart.com/license-agreement.html for license details.
  6.  */
  8. namespace XCart\Messenger\EventListener;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Filesystem\Filesystem;
  12. use Symfony\Component\Messenger\Event\WorkerRunningEvent;
  13. use Symfony\Component\Messenger\Event\WorkerStartedEvent;
  14. use Symfony\Component\Messenger\Event\WorkerStoppedEvent;
  16. final class WorkersRegistryEventListener implements EventSubscriberInterface
  17. {
  18.     private Filesystem $filesystem;
  20.     private string $workersPoolPath;
  22.     /**
  23.      * @var false|int
  24.      */
  25.     private $pid;
  27.     public function __construct(Filesystem $filesystem, string $workersPoolPath)
  28.     {
  29.         $this->filesystem = $filesystem;
  30.         $this->workersPoolPath = $workersPoolPath;
  32.         $this->pid = getmypid();
  33.     }
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             WorkerStartedEvent::class => 'onWorkerStarted',
  39.             WorkerStoppedEvent::class => 'onWorkerStopped',
  40.             WorkerRunningEvent::class => 'onWorkerRunning',
  41.         ];
  42.     }
  44.     public function onWorkerStarted(): void
  45.     {
  46.         $this->filesystem->dumpFile($this->workersPoolPath . $this->pid, microtime(true));
  48.         if (function_exists('pcntl_signal')) {
  49.             pcntl_signal(\SIGINT, function () {
  50.                 $this->onWorkerStopped();
  51.                 // We should only write remove our flag and exit, should not resume execution or wait for graceful stop
  52.                 exit();
  53.             });
  54.         }
  55.     }
  57.     public function onWorkerRunning(): void
  58.     {
  59.         $this->filesystem->dumpFile($this->workersPoolPath . $this->pid, microtime(true));
  60.     }
  62.     public function onWorkerStopped(): void
  63.     {
  64.         $this->filesystem->remove($this->workersPoolPath . $this->pid);
  65.     }
  66. }