$io =
new SymfonyStyle($input,
$output instanceof ConsoleOutputInterface ?
$output->
getErrorOutput() :
$output);
if ($this->receiverNames && !
$input->
getArgument('receivers'
)) { $io->
block('Which transports/receivers do you want to consume?', null, 'fg=white;bg=blue', ' ', true
);
$io->
writeln('Choose which receivers you want to consume messages from in order of priority.'
);
if (\
count($this->receiverNames
) > 1
) { $io->
writeln(sprintf('Hint: to consume from multiple, use a list of their names, e.g. <comment>%s</comment>',
implode(', ',
$this->receiverNames
)));
} $question =
new ChoiceQuestion('Select receivers to consume:',
$this->receiverNames, 0
);
$question->
setMultiselect(true
);
$input->
setArgument('receivers',
$io->
askQuestion($question));
} if (!
$input->
getArgument('receivers'
)) { throw new RuntimeException('Please pass at least one receiver.'
);
} } protected function execute(InputInterface
$input, OutputInterface
$output): int
{