vendor/symfony/messenger/EventListener/StopWorkerOnSigtermSignalListener.php line 30

Open in your IDE?
  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\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Messenger\Event\WorkerStartedEvent;
  18. /**
  19. * @author Tobias Schultze <http://tobion.de>
  20. */
  21. class StopWorkerOnSigtermSignalListener implements EventSubscriberInterface
  22. {
  23. private $logger;
  25. public function __construct(?LoggerInterface $logger = null)
  26. {
  27. $this->logger = $logger;
  28. }
  30. public function onWorkerStarted(WorkerStartedEvent $event): void
  31. {
  32. pcntl_signal(\SIGTERM, function () use ($event) {
  33. if (null !== $this->logger) {
  34. $this->logger->info('Received SIGTERM signal.', ['transport_names' => $event->getWorker()->getMetadata()->getTransportNames()]);
  35. }
  37. $event->getWorker()->stop();
  38. });
  39. }
  41. public static function getSubscribedEvents()
  42. {
  43. if (!\function_exists('pcntl_signal')) {
  44. return [];
  45. }
  47. return [
  48. WorkerStartedEvent::class => ['onWorkerStarted', 100],
  49. ];
  50. }
  51. }