Exchange.php

Go to the documentation of this file.

<?php
namespace Magento\Amqp\Model;

use Magento\Framework\MessageQueue\ConfigInterface as QueueConfig;
use Magento\Framework\Communication\ConfigInterface as CommunicationConfigInterface;
use Magento\Framework\MessageQueue\Publisher\ConfigInterface as PublisherConfig;
use Magento\Framework\MessageQueue\Rpc\ResponseQueueNameBuilder;

class Exchange extends \Magento\Framework\Amqp\Exchange
{
    public function __construct(
        Config $amqpConfig,
        QueueConfig $queueConfig,
        CommunicationConfigInterface $communicationConfig,
        $rpcConnectionTimeout = self::RPC_CONNECTION_TIMEOUT
    ) {
        parent::__construct(
            $amqpConfig,
            $this->getPublisherConfig(),
            $this->getResponseQueueNameBuilder(),
            $communicationConfig,
            $rpcConnectionTimeout
        );
    }

    private function getPublisherConfig()
    {
        return \Magento\Framework\App\ObjectManager::getInstance()->get(PublisherConfig::class);
    }

    private function getResponseQueueNameBuilder()
    {
        return \Magento\Framework\App\ObjectManager::getInstance()->get(ResponseQueueNameBuilder::class);
    }
}