mirror of
https://github.com/bdnugget/magento2.git
synced 2026-11-07 09:17:35 +00:00
95 lines
2.3 KiB
PHP
95 lines
2.3 KiB
PHP
<?php
|
|
/**
|
|
* Copyright © Magento, Inc. All rights reserved.
|
|
* See COPYING.txt for license details.
|
|
*/
|
|
namespace Magento\MessageQueue\Console;
|
|
|
|
use Symfony\Component\Console\Application;
|
|
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
|
|
{
|
|
public 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();
|
|
}
|
|
|
|
/**
|
|
* Get Consumers
|
|
*
|
|
* @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
|
|
* @see MAGETWO-71174
|
|
*/
|
|
private function getConsumerConfig()
|
|
{
|
|
if ($this->consumerConfig === null) {
|
|
$this->consumerConfig = \Magento\Framework\App\ObjectManager::getInstance()->get(ConsumerConfig::class);
|
|
}
|
|
return $this->consumerConfig;
|
|
}
|
|
}
|