Final Class Yiisoft\Queue\Command\RunCommand

                public function __construct(
    private readonly QueueConsumerProviderInterface $queueProvider,
) {
    parent::__construct();
}

            

                public function configure(): void
{
    $this->addArgument(
        'queue',
        InputArgument::OPTIONAL | InputArgument::IS_ARRAY,
        'Queue name list to connect to.',
        [],
    )
        ->addOption(
            'limit',
            'm',
            InputOption::VALUE_REQUIRED,
            'Maximum number of messages to process in each queue. Default is 0 (no limits).',
            0,
        )
        ->addUsage('[queue1 [queue2 [...]]] --limit 100');
}

            

                protected function execute(InputInterface $input, OutputInterface $output): int
{
    /** @var string[] $queueNames */
    $queueNames = $input->getArgument('queue');
    if ($queueNames === []) {
        $queueNames = $this->queueProvider->getConsumerQueueNames();
    }
    /** @var string $queueName */
    foreach ($queueNames as $queueName) {
        $queueConsumer = $this->queueProvider->getConsumer($queueName);
        $output->write("Processing queue $queueName... ");
        $count = $queueConsumer->run((int) $input->getOption('limit'));
        $output->writeln("Messages processed: $count.");
    }
    return 0;
}