TopologyInstaller Class Reference

Inheritance diagram for TopologyInstaller:

Public Member Functions
	__construct (ConfigInterface $topologyConfig, ExchangeInstaller $exchangeInstaller, ConfigPool $configPool, QueueInstaller $queueInstaller, ConnectionTypeResolver $connectionTypeResolver, \Psr\Log\LoggerInterface $logger)
	install ()

Protected Attributes
	$logger

Detailed Description

Class Topology creates topology for Amqp messaging

Definition at line 15 of file TopologyInstaller.php.

Constructor & Destructor Documentation

__construct()

__construct	(	ConfigInterface	$topologyConfig,
		ExchangeInstaller	$exchangeInstaller,
		ConfigPool	$configPool,
		QueueInstaller	$queueInstaller,
		ConnectionTypeResolver	$connectionTypeResolver,
		\Psr\Log\LoggerInterface	$logger
	)

Initialize dependencies.

Parameters

ConfigInterface	$topologyConfig
ExchangeInstaller	$exchangeInstaller
ConfigPool	$configPool
QueueInstaller	$queueInstaller
ConnectionTypeResolver	$connectionTypeResolver
\Psr\Log\LoggerInterface	$logger

Definition at line 57 of file TopologyInstaller.php.

      {
        $this->topologyConfig = $topologyConfig;
        $this->exchangeInstaller = $exchangeInstaller;
        $this->configPool = $configPool;
        $this->queueInstaller = $queueInstaller;
        $this->connectionTypeResolver = $connectionTypeResolver;
        $this->logger = $logger;
    }

Member Function Documentation

install()

install

(

)

Install Amqp Exchanges, Queues and bind them

Returns

void

Definition at line 78 of file TopologyInstaller.php.

    {
        try {
            foreach ($this->topologyConfig->getQueues() as $queue) {
                if ($this->connectionTypeResolver->getConnectionType($queue->getConnection()) != 'amqp') {
                    continue;
                }
                $amqpConfig = $this->configPool->get($queue->getConnection());
                $this->queueInstaller->install($amqpConfig->getChannel(), $queue);
            }
            foreach ($this->topologyConfig->getExchanges() as $exchange) {
                if ($this->connectionTypeResolver->getConnectionType($exchange->getConnection()) != 'amqp') {
                    continue;
                }
                $amqpConfig = $this->configPool->get($exchange->getConnection());
                $this->exchangeInstaller->install($amqpConfig->getChannel(), $exchange);
            }
        } catch (\Exception $e) {
            $this->logger->error("AMQP topology installation failed: {$e->getMessage()}\n{$e->getTraceAsString()}");
        }
    }

Field Documentation

$logger

$logger

protected

Definition at line 45 of file TopologyInstaller.php.

---

The documentation for this class was generated from the following file:

• vendor/magento/framework-amqp/TopologyInstaller.php