Use yiisoft/yii-console with optional.

README.md

@@ -37,6 +37,42 @@ or add
 
 to the `require` section of your `composer.json` file.
 
+## Usage with Yii Console
+
+Just install `yiisoft/yii-console` package and you are ready to go.
+
+## Usage with Symfony Console
+
+1. Copy configuration file `./vendor/yiisoft/yii-queue/bin/definitions.php` to `root` folder of your project.
+
+```shell
+cp ./vendor/yiisoft/yii-queue/bin/definitions.php ./
+```
+
+2. Edit `./definitions.php` and add definitions for your logger and queue adapter.
+
+Here's a sample configuration.
+
+```php
+use Psr\Log\LoggerInterface;
+use Yiisoft\Definitions\ReferencesArray;
+use Yiisoft\Log\Logger;
+use Yiisoft\Log\Target\File\FileTarget;
+
+return [
+    LoggerInterface::class => [
+        'class' => Logger::class,
+        '__construct()' => [
+            'targets' => ReferencesArray::from(
+                [
+                    FileTarget::class
+                ],
+            ),
+        ],
+    ],
+];
+```
+
 ## Ready for yiisoft/config
 
 If you are using [yiisoft/config](https://github.com/yiisoft/config), you'll find out this package has some defaults

bin/definitions.php

@@ -0,0 +1,71 @@
+<?php
+
+declare(strict_types=1);
+
+use Psr\Container\ContainerInterface;
+use Symfony\Component\Console\Application;
+use Yiisoft\Definitions\ReferencesArray;
+use Yiisoft\Yii\Queue\Cli\LoopInterface;
+use Yiisoft\Yii\Queue\Cli\SignalLoop;
+use Yiisoft\Yii\Queue\Cli\SimpleLoop;
+use Yiisoft\Yii\Queue\Command\ListenCommand;
+use Yiisoft\Yii\Queue\Command\RunCommand;
+use Yiisoft\Yii\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
+use Yiisoft\Yii\Queue\Middleware\Consume\MiddlewareFactoryConsume;
+use Yiisoft\Yii\Queue\Middleware\Consume\MiddlewareFactoryConsumeInterface;
+use Yiisoft\Yii\Queue\Middleware\FailureHandling\FailureMiddlewareDispatcher;
+use Yiisoft\Yii\Queue\Middleware\FailureHandling\MiddlewareFactoryFailure;
+use Yiisoft\Yii\Queue\Middleware\FailureHandling\MiddlewareFactoryFailureInterface;
+use Yiisoft\Yii\Queue\Middleware\Push\MiddlewareFactoryPush;
+use Yiisoft\Yii\Queue\Middleware\Push\MiddlewareFactoryPushInterface;
+use Yiisoft\Yii\Queue\Middleware\Push\PushMiddlewareDispatcher;
+use Yiisoft\Yii\Queue\Queue;
+use Yiisoft\Yii\Queue\QueueFactory;
+use Yiisoft\Yii\Queue\QueueFactoryInterface;
+use Yiisoft\Yii\Queue\QueueInterface;
+use Yiisoft\Yii\Queue\Worker\Worker as QueueWorker;
+use Yiisoft\Yii\Queue\Worker\WorkerInterface;
+
+return [
+    Application::class => [
+        '__construct()' => [
+            'name' => 'Yii Queue Tool',
+            'version' => '1.0.0',
+        ],
+        'addCommands()' => [
+            ReferencesArray::from(
+                [
+                    RunCommand::class,
+                    ListenCommand::class,
+                ],
+            ),
+        ],
+    ],
+    QueueWorker::class => [
+        'class' => QueueWorker::class,
+        '__construct()' => [[]],
+    ],
+    WorkerInterface::class => QueueWorker::class,
+    LoopInterface::class => static function (ContainerInterface $container): LoopInterface {
+        return extension_loaded('pcntl')
+            ? $container->get(SignalLoop::class)
+            : $container->get(SimpleLoop::class);
+    },
+    QueueFactoryInterface::class => QueueFactory::class,
+    QueueFactory::class => [
+        '__construct()' => [[]],
+    ],
+    QueueInterface::class => Queue::class,
+    MiddlewareFactoryPushInterface::class => MiddlewareFactoryPush::class,
+    MiddlewareFactoryConsumeInterface::class => MiddlewareFactoryConsume::class,
+    MiddlewareFactoryFailureInterface::class => MiddlewareFactoryFailure::class,
+    PushMiddlewareDispatcher::class => [
+        '__construct()' => ['middlewareDefinitions' => []],
+    ],
+    ConsumeMiddlewareDispatcher::class => [
+        '__construct()' => ['middlewareDefinitions' => []],
+    ],
+    FailureMiddlewareDispatcher::class => [
+        '__construct()' => ['middlewareDefinitions' => []],
+    ],
+];

bin/queue

@@ -0,0 +1,27 @@
+#!/usr/bin/env php
+<?php
+
+declare(strict_types=1);
+
+use Psr\Log\LoggerInterface;
+use Symfony\Component\Console\Application;
+use Yiisoft\Di\Container;
+use Yiisoft\Di\ContainerConfig;
+
+require_once './vendor/autoload.php';
+
+/** @var array $definitions */
+$definitions = require_once 'definitions.php';
+
+$containerConfig = ContainerConfig::create()->withDefinitions($definitions);
+$container = new Container($containerConfig);
+
+if ($container->has(LoggerInterface::class) === false) {
+    throw new RuntimeException(
+        'Logger is not configured, install your logger of choice and configure it properly in /bin/definitions.php.'
+    );
+}
+
+/** @var Application $application */
+$application = $container->get(Application::class);
+$application->run();

bin/queue.bat

@@ -0,0 +1,11 @@
+@echo off
+
+@setlocal
+
+set YII_PATH=%~dp0
+
+if "%PHP_COMMAND%" == "" set PHP_COMMAND=php.exe
+
+"%PHP_COMMAND%" "%YII_PATH%queue" %*
+
+@endlocal

composer.json

@@ -29,7 +29,6 @@
         "php": "^8.0",
         "psr/log": "^2.0|^3.0",
         "psr/container": "^1.0|^2.0",
-        "yiisoft/yii-console": "^2.0",
         "yiisoft/definitions": "^1.0|^2.0|^3.0",
         "yiisoft/friendly-exception": "^1.0",
         "yiisoft/injector": "^1.0",
@@ -41,9 +40,10 @@
         "rector/rector": "^0.18.10",
         "roave/infection-static-analysis-plugin": "^1.16",
         "spatie/phpunit-watcher": "^1.23",
-        "yiisoft/yii-debug": "dev-master",
         "vimeo/psalm": "^4.30|^5.8",
-        "yiisoft/test-support": "^3.0"
+        "yiisoft/test-support": "^3.0",
+        "yiisoft/yii-console": "^2.0",
+        "yiisoft/yii-debug": "dev-master"
     },
     "suggest": {
         "ext-pcntl": "Need for process signals"
@@ -58,6 +58,9 @@
             "Yiisoft\\Yii\\Queue\\Tests\\": "tests"
         }
     },
+    "bin": [
+        "bin/queue"
+    ],
     "extra": {
         "branch-alias": {
             "dev-master": "3.0.x-dev"

src/Command/ListenCommand.php

@@ -8,7 +8,6 @@
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
-use Yiisoft\Yii\Console\ExitCode;
 use Yiisoft\Yii\Queue\QueueFactory;
 use Yiisoft\Yii\Queue\QueueFactoryInterface;
 
@@ -38,6 +37,6 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             ->get($input->getArgument('channel'))
             ->listen();
 
-        return ExitCode::OK;
+        return 0;
     }
 }

src/Command/RunCommand.php

@@ -8,7 +8,6 @@
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
-use Yiisoft\Yii\Console\ExitCode;
 use Yiisoft\Yii\Queue\QueueFactory;
 use Yiisoft\Yii\Queue\QueueFactoryInterface;
 
@@ -38,6 +37,6 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             ->get($input->getArgument('channel'))
             ->run();
 
-        return ExitCode::OK;
+        return 0;
     }
 }