vendor/symfony/messenger/EventListener/StopWorkerOnSignalsListener.php line 39

  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Messenger\EventListener;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\Console\Command\SignalableCommandInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Messenger\Event\WorkerStartedEvent;
  19. /**
  20.  * @author Tobias Schultze <http://tobion.de>
  21.  * @author Grégoire Pineau <lyrixx@lyrixx.info>
  22.  *
  23.  * @deprecated since Symfony 6.4, use the {@see SignalableCommandInterface} instead
  24.  */
  25. class StopWorkerOnSignalsListener implements EventSubscriberInterface
  26. {
  27.     private array $signals;
  28.     private ?LoggerInterface $logger;
  30.     public function __construct(?array $signals = null, ?LoggerInterface $logger = null)
  31.     {
  32.         if (null === $signals && \extension_loaded('pcntl')) {
  33.             $signals = [\SIGTERM, \SIGINT];
  34.         }
  35.         $this->signals = $signals ?? [];
  36.         $this->logger = $logger;
  37.     }
  39.     public function onWorkerStarted(WorkerStartedEvent $event): void
  40.     {
  41.         foreach ($this->signals as $signal) {
  42.             pcntl_signal($signal, function () use ($event, $signal) {
  43.                 $this->logger?->info('Received signal {signal}.', ['signal' => $signal, 'transport_names' => $event->getWorker()->getMetadata()->getTransportNames()]);
  45.                 $event->getWorker()->stop();
  46.             });
  47.         }
  48.     }
  50.     public static function getSubscribedEvents(): array
  51.     {
  52.         if (!\function_exists('pcntl_signal')) {
  53.             return [];
  54.         }
  56.         return [
  57.             WorkerStartedEvent::class => ['onWorkerStarted', 100],
  58.         ];
  59.     }
  60. }