addArgument( "number", InputArgument::REQUIRED, 'Number of DIE messages to send to each targeted consumer queue.' ); $this->addArgument( "queue", InputArgument::OPTIONAL, 'A queue whose consumers are to reload.' ); $this->addOption( 'label', 'l', InputOption::VALUE_OPTIONAL, 'Comma-separated consumer labels to restart (see consume --label). Empty targets the shared DIE queue.' ); } protected function executeCommand(InputInterface $input, OutputInterface $output): int { // Labely cílí restart na konkrétní konzumery (každý má vlastní DIE frontu "0_"). // Bez labelu se posílá do sdílené DIE fronty - zpětně kompatibilní původní chování. $labels = $input->getOption('label'); $labels = $labels ? explode(',', $labels) : [null]; $queue = $this->backgroundQueue->getQueue($input->getArgument("queue")); foreach ($labels as $label) { for ($i = 0; $i < $input->getArgument("number"); $i++) { $this->producer->publishDie($queue, $label); } } return self::SUCCESS; } }