diff --git a/pkg/enqueue/Consumption/Extension/SignalExtension.php b/pkg/enqueue/Consumption/Extension/SignalExtension.php index a3bab8500..aeeadff28 100644 --- a/pkg/enqueue/Consumption/Extension/SignalExtension.php +++ b/pkg/enqueue/Consumption/Extension/SignalExtension.php @@ -18,7 +18,7 @@ class SignalExtension implements ExtensionInterface protected $interruptConsumption = false; /** - * @var LoggerInterface + * @var LoggerInterface|null */ protected $logger; @@ -84,7 +84,10 @@ public function onIdle(Context $context) public function interruptExecutionIfNeeded(Context $context) { if (false == $context->isExecutionInterrupted() && $this->interruptConsumption) { - $this->logger->debug('[SignalExtension] Interrupt execution'); + if ($this->logger) { + $this->logger->debug('[SignalExtension] Interrupt execution'); + } + $context->setExecutionInterrupted($this->interruptConsumption); $this->interruptConsumption = false; @@ -104,7 +107,10 @@ public function handleSignal($signal) case SIGTERM: // 15 : supervisor default stop case SIGQUIT: // 3 : kill -s QUIT case SIGINT: // 2 : ctrl+c - $this->logger->debug('[SignalExtension] Interrupt consumption'); + if ($this->logger) { + $this->logger->debug('[SignalExtension] Interrupt consumption'); + } + $this->interruptConsumption = true; break; default: