Converter.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue\Consumer\Config\Xml;

use Magento\Framework\MessageQueue\DefaultValueProvider;
use Magento\Framework\MessageQueue\ConsumerInterface;
use Magento\Framework\Communication\Config\ConfigParser;
use Magento\Framework\Communication\ConfigInterface as CommunicationConfig;

class Converter implements \Magento\Framework\Config\ConverterInterface
{
    private static $defaultInstance = ConsumerInterface::class;

    private $configParser;

    private $defaultValueProvider;

    public function __construct(ConfigParser $configParser, DefaultValueProvider $defaultValueProvider)
    {
        $this->configParser = $configParser;
        $this->defaultValueProvider = $defaultValueProvider;
    }

    public function convert($source)
    {
        $result = [];
        foreach ($source->getElementsByTagName('consumer') as $consumerNode) {
            $consumerName = $this->getAttributeValue($consumerNode, 'name');
            $handler = $this->getAttributeValue($consumerNode, 'handler');
            $result[$consumerName] = [
                'name' => $consumerName,
                'queue' => $this->getAttributeValue($consumerNode, 'queue'),
                'consumerInstance' => $this->getAttributeValue(
                    $consumerNode,
                    'consumerInstance',
                    self::$defaultInstance
                ),
                'handlers' => $handler ? [$this->parseHandler($handler)] : [],
                'connection' => $this->getAttributeValue(
                    $consumerNode,
                    'connection',
                    $this->defaultValueProvider->getConnection()
                ),
                'maxMessages' => $this->getAttributeValue($consumerNode, 'maxMessages')
            ];
        }
        return $result;
    }

    private function getAttributeValue(\DOMNode $node, $attributeName, $default = null)
    {
        $item = $node->attributes->getNamedItem($attributeName);
        return $item ? $item->nodeValue : $default;
    }

    private function parseHandler($handler)
    {
        $parseServiceMethod = $this->configParser->parseServiceMethod($handler);
        return [
            CommunicationConfig::HANDLER_TYPE => $parseServiceMethod[ConfigParser::TYPE_NAME],
            CommunicationConfig::HANDLER_METHOD => $parseServiceMethod[ConfigParser::METHOD_NAME]
        ];
    }
}