diff --git a/Command/ConsumeMessagesCommand.php b/Command/ConsumeMessagesCommand.php index f430a28..9746c5e 100644 --- a/Command/ConsumeMessagesCommand.php +++ b/Command/ConsumeMessagesCommand.php @@ -258,7 +258,7 @@ public function complete(CompletionInput $input, CompletionSuggestions $suggesti public function getSubscribedSignals(): array { - return $this->signals ?? (\defined('SIGTERM') ? [\SIGTERM, \SIGINT] : []); + return $this->signals ?? (\extension_loaded('pcntl') ? [\SIGTERM, \SIGINT] : []); } public function handleSignal(int $signal, int|false $previousExitCode = 0): int|false diff --git a/Command/FailedMessagesRetryCommand.php b/Command/FailedMessagesRetryCommand.php index ae47d77..53e70bb 100644 --- a/Command/FailedMessagesRetryCommand.php +++ b/Command/FailedMessagesRetryCommand.php @@ -134,7 +134,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int public function getSubscribedSignals(): array { - return $this->signals ?? (\defined('SIGTERM') ? [\SIGTERM, \SIGINT] : []); + return $this->signals ?? (\extension_loaded('pcntl') ? [\SIGTERM, \SIGINT] : []); } public function handleSignal(int $signal, int|false $previousExitCode = 0): int|false diff --git a/EventListener/StopWorkerOnSignalsListener.php b/EventListener/StopWorkerOnSignalsListener.php index 6641d41..54f93ae 100644 --- a/EventListener/StopWorkerOnSignalsListener.php +++ b/EventListener/StopWorkerOnSignalsListener.php @@ -29,7 +29,7 @@ class StopWorkerOnSignalsListener implements EventSubscriberInterface public function __construct(array $signals = null, LoggerInterface $logger = null) { - if (null === $signals && \defined('SIGTERM')) { + if (null === $signals && \extension_loaded('pcntl')) { $signals = [\SIGTERM, \SIGINT]; } $this->signals = $signals ?? []; diff --git a/EventListener/StopWorkerOnSigtermSignalListener.php b/EventListener/StopWorkerOnSigtermSignalListener.php index 4f76b1e..2d7c8f1 100644 --- a/EventListener/StopWorkerOnSigtermSignalListener.php +++ b/EventListener/StopWorkerOnSigtermSignalListener.php @@ -25,6 +25,6 @@ class StopWorkerOnSigtermSignalListener extends StopWorkerOnSignalsListener { public function __construct(LoggerInterface $logger = null) { - parent::__construct(\defined('SIGTERM') ? [\SIGTERM] : [], $logger); + parent::__construct(\extension_loaded('pcntl') ? [\SIGTERM] : [], $logger); } }