Topology.php

Go to the documentation of this file.

<?php
namespace Magento\Amqp\Model;

use Magento\Framework\Amqp\Topology\ExchangeInstaller;
use Magento\Framework\Amqp\Topology\QueueInstaller;
use Magento\Framework\MessageQueue\ConfigInterface as QueueConfig;
use Magento\Framework\Communication\ConfigInterface as CommunicationConfig;
use Magento\Framework\MessageQueue\Topology\ConfigInterface as TopologyConfig;
use Magento\Framework\Amqp\ConfigPool;
use Magento\Framework\Amqp\ConnectionTypeResolver;
use Magento\Framework\Amqp\TopologyInstaller;

class Topology extends TopologyInstaller
{
    const TOPIC_EXCHANGE = 'topic';

    const AMQP_CONNECTION = 'amqp';

    const IS_DURABLE = true;

    public function __construct(
        Config $amqpConfig,
        QueueConfig $queueConfig,
        CommunicationConfig $communicationConfig,
        \Psr\Log\LoggerInterface $logger
    ) {
        parent::__construct(
            \Magento\Framework\App\ObjectManager::getInstance()->get(TopologyConfig::class),
            \Magento\Framework\App\ObjectManager::getInstance()->get(ExchangeInstaller::class),
            \Magento\Framework\App\ObjectManager::getInstance()->get(ConfigPool::class),
            \Magento\Framework\App\ObjectManager::getInstance()->get(QueueInstaller::class),
            \Magento\Framework\App\ObjectManager::getInstance()->get(ConnectionTypeResolver::class),
            $logger
        );
    }
}