DeprecatedConfigTest.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue\Publisher;

use Magento\Framework\MessageQueue\Publisher\Config\PublisherConnectionInterface;

class DeprecatedConfigTest extends \PHPUnit\Framework\TestCase
{
    private $objectManager;

    protected function setUp()
    {
        $this->objectManager = \Magento\TestFramework\Helper\Bootstrap::getObjectManager();
    }

    public function testGetPublisher()
    {
        $config = $this->objectManager->create(\Magento\Framework\MessageQueue\Publisher\ConfigInterface::class);
        $publisher = $config->getPublisher('deprecated.config.async.string.topic');
        $this->assertEquals('deprecated.config.async.string.topic', $publisher->getTopic());
        $this->assertEquals(false, $publisher->isDisabled());

        $connection = $publisher->getConnection();
        $this->assertEquals('amqp', $connection->getName());
        $this->assertEquals('magento', $connection->getExchange());
        $this->assertEquals(false, $connection->isDisabled());
    }

    public function testGetPublisherCustomConnection()
    {
        $config = $this->objectManager->create(\Magento\Framework\MessageQueue\Publisher\ConfigInterface::class);
        $publisher = $config->getPublisher('deprecated.config.sync.bool.topic');
        $this->assertEquals('deprecated.config.sync.bool.topic', $publisher->getTopic());
        $this->assertEquals(false, $publisher->isDisabled());

        $connection = $publisher->getConnection();
        $this->assertEquals('amqp', $connection->getName());
        $this->assertEquals('customExchange', $connection->getExchange());
        $this->assertEquals(false, $connection->isDisabled());
    }

    public function testGetOverlapWithQueueConfig()
    {
        $config = $this->objectManager->create(\Magento\Framework\MessageQueue\Publisher\ConfigInterface::class);
        $publisher = $config->getPublisher('overlapping.topic.declaration');
        $this->assertEquals('overlapping.topic.declaration', $publisher->getTopic());
        $this->assertEquals(false, $publisher->isDisabled());

        $connection = $publisher->getConnection();
        $this->assertEquals('amqp', $connection->getName());
        $this->assertEquals('magento', $connection->getExchange());
        $this->assertEquals(false, $connection->isDisabled());
    }
}