#552 Move signal handling from queue component to controller

CHANGELOG.md

@@ -14,6 +14,7 @@ Yii2 Queue Extension Change Log
 - Enh #503: All dependent packages for supported drivers have been updated to the latest versions (@s1lver)
 - Enh #503: The `opis/closure` package did not support PHP 8.1 and was replaced by the `laravel/serializable-closure` package (@s1lver)
 - Enh #544: Applying Yii2 coding standards (@s1lver)
+- Enh #552: Move signal handling from AMQP Interop queue component to controller (@snewer)
 
 2.3.8 January 08, 2026
 ----------------------

src/drivers/amqp_interop/Command.php

@@ -26,6 +26,38 @@ class Command extends CliCommand
      */
     public CliQueue $queue;
 
+    /**
+     * @inheritdoc
+     */
+    public function init(): void
+    {
+        parent::init();
+
+        // https://github.com/yiisoft/yii2-queue/issues/379
+        if (extension_loaded('pcntl') && function_exists('pcntl_signal')) {
+            // https://github.com/php-amqplib/php-amqplib#unix-signals
+            $signals = [SIGTERM, SIGQUIT, SIGINT, SIGHUP];
+
+            foreach ($signals as $signal) {
+                /** @var (callable(int):void)|int|null $oldHandler */
+                $oldHandler = null;
+                // This got added in php 7.1 and might not exist on all supported versions
+                if (function_exists('pcntl_signal_get_handler')) {
+                    $oldHandler = pcntl_signal_get_handler($signal);
+                }
+
+                pcntl_signal($signal, static function ($signal) use ($oldHandler) {
+                    if ($oldHandler && is_callable($oldHandler)) {
+                        $oldHandler($signal);
+                    }
+
+                    pcntl_signal($signal, SIG_DFL);
+                    posix_kill(posix_getpid(), $signal);
+                });
+            }
+        }
+    }
+
     /**
      * @inheritdoc
      */

src/drivers/amqp_interop/Queue.php

@@ -294,28 +294,6 @@ public function init(): void
         Event::on(BaseApp::class, BaseApp::EVENT_AFTER_REQUEST, function () {
             $this->close();
         });
-
-        if (extension_loaded('pcntl') && function_exists('pcntl_signal') && PHP_MAJOR_VERSION >= 7) {
-            // https://github.com/php-amqplib/php-amqplib#unix-signals
-            $signals = [SIGTERM, SIGQUIT, SIGINT, SIGHUP];
-
-            foreach ($signals as $signal) {
-                $oldHandler = null;
-                // This got added in php 7.1 and might not exist on all supported versions
-                if (function_exists('pcntl_signal_get_handler')) {
-                    $oldHandler = pcntl_signal_get_handler($signal);
-                }
-
-                pcntl_signal($signal, static function ($signal) use ($oldHandler) {
-                    if ($oldHandler && is_callable($oldHandler)) {
-                        $oldHandler($signal);
-                    }
-
-                    pcntl_signal($signal, SIG_DFL);
-                    posix_kill(posix_getpid(), $signal);
-                });
-            }
-        }
     }
 
     /**