Использование другой очереди заданий about yii2-command-bus HOT 4 CLOSED

use trntv\bus\interfaces\SelfHandlingCommand;
use yii\base\Object;
use \zhuravljov\yii\queue\Job;

class NotificationCommand extends Object implements Job, SelfHandlingCommand
{
    public function handle($command)
    {
        \Yii::$app->queue->push(new $this);
    }

    public function run()
    {
        //тут выполняю нужные действия
    }
}

'middlewares' => [
                [
                    'class' => '\common\commands\middlewares\QueuedCommandMiddleware',
                ],
            ]

use trntv\bus\interfaces\Middleware;
use yii\base\Object;
use zhuravljov\yii\queue\Job;

/*
 * Это класс - прослойка для командной шины, чтобы отправлять задания
 * в очередь zhuravljov\yii2-queue
 */
class QueuedCommandMiddleware extends Object implements Middleware
{
    /**
     * @param $command
     * @param callable $next
     * @return string
     */
    public function execute($command, callable $next)
    {
        if ($command instanceof Job) {
            return \Yii::$app->queue->push($command);
        }
        return $next($command);
    }
}

use yii\base\Object;
use trntv\bus\interfaces\SelfHandlingCommand;
use zhuravljov\yii\queue\Job;

class NotificationCommand extends Object implements SelfHandlingCommand, Job
{
    public $importantData;

    public function handle($command)
    {
        //тут делаем, что хотим
    }

    public function run()
    {
        $this->handle(null);
    }
}

Yii::$app->commandBus->handle(new NotificationCommand(
            ['importantData' => []]
        ));