123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990 |
- <?php
- /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
- */
- namespace Magento\MessageQueue\Console;
- use Symfony\Component\Console\Command\Command;
- use Magento\Framework\MessageQueue\ConfigInterface as QueueConfig;
- use Symfony\Component\Console\Input\InputInterface;
- use Symfony\Component\Console\Output\OutputInterface;
- use Magento\Framework\MessageQueue\Consumer\ConfigInterface as ConsumerConfig;
- /**
- * Command for starting MessageQueue consumers.
- */
- class ConsumerListCommand extends Command
- {
- const COMMAND_QUEUE_CONSUMERS_LIST = 'queue:consumers:list';
- /**
- * @var ConsumerConfig
- */
- private $consumerConfig;
- /**
- * Initialize dependencies.
- *
- * @param QueueConfig $queueConfig
- * @param string|null $name
- *
- * @SuppressWarnings(PHPMD.UnusedFormalParameter)
- */
- public function __construct(QueueConfig $queueConfig, $name = null)
- {
- parent::__construct($name);
- }
- /**
- * {@inheritdoc}
- */
- protected function execute(InputInterface $input, OutputInterface $output)
- {
- $consumers = $this->getConsumers();
- $output->writeln($consumers);
- return \Magento\Framework\Console\Cli::RETURN_SUCCESS;
- }
- /**
- * {@inheritdoc}
- */
- protected function configure()
- {
- $this->setName(self::COMMAND_QUEUE_CONSUMERS_LIST);
- $this->setDescription('List of MessageQueue consumers');
- $this->setHelp(
- <<<HELP
- This command shows list of MessageQueue consumers.
- HELP
- );
- parent::configure();
- }
- /**
- * @return string[]
- */
- private function getConsumers()
- {
- $consumerNames = [];
- foreach ($this->getConsumerConfig()->getConsumers() as $consumer) {
- $consumerNames[] = $consumer->getName();
- }
- return $consumerNames;
- }
- /**
- * Get consumer config.
- *
- * @return ConsumerConfig
- *
- * @deprecated 100.2.0
- */
- private function getConsumerConfig()
- {
- if ($this->consumerConfig === null) {
- $this->consumerConfig = \Magento\Framework\App\ObjectManager::getInstance()->get(ConsumerConfig::class);
- }
- return $this->consumerConfig;
- }
- }
|