class QueueClientConsumerConsoleCommandPlugin extends AbstractCommandPlugin
23
{
24
public const COMMAND_NAME = 'queue:client:consumer';
25
public const DESCRIPTION = 'This command will consume messages in topics and call related processors.';
26
public const ARGUMENT_QUEUE_NAME = 'queue_name';
27
28
protected function configure(): void
29
{
30
$this->setName(self::COMMAND_NAME);
31
$this->setDescription(self::DESCRIPTION);
32
$this->addArgument(self::ARGUMENT_QUEUE_NAME, InputArgument::REQUIRED, 'Please add one of your registered Queue Plugins (QueuePluginCollection) as an argument.');
33
34
parent::configure();
35
}
36
37
protected function execute(InputInterface $input, OutputInterface $output): int