Cmobi\RabbitmqBundle\Tests\DependencyInjection\Compiler\SubscriberPassTest

Complexity

Total Complexity

3

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	testProcess()	0	13	1
A	declareServiceMock()	0	8	1
A	process()	0	13	1

<?php

namespace Cmobi\RabbitmqBundle\Tests\DependencyInjection\Compiler;

use Cmobi\RabbitmqBundle\Connection\ConnectionManager;
use Cmobi\RabbitmqBundle\DependencyInjection\CmobiRabbitmqExtension;
use Cmobi\RabbitmqBundle\DependencyInjection\Compiler\SubscriberPass;
use Cmobi\RabbitmqBundle\Queue\BaseQueueService;
use Cmobi\RabbitmqBundle\Tests\BaseTestCase;
use Cmobi\RabbitmqBundle\Transport\Subscriber\ExchangeType;
use Symfony\Component\DependencyInjection\ContainerBuilder;

class SubscriberPassTest extends BaseTestCase
{
    public function testProcess()
    {
        $container = new ContainerBuilder();
        $this->declareServiceMock($container);
        $container->register('cmobi_rabbitmq.message.handler', BaseQueueService::class)
            ->setPublic(false);
        $container->register('cmobi_rabbitmq.connection.manager', ConnectionManager::class)
            ->setPublic(false);

        $this->process($container);

        $this->assertTrue($container->hasDefinition('cmobi_rabbitmq.pub_sub.test'));
    }

    private function declareServiceMock(ContainerBuilder $container)
    {
        $container->registerExtension(new CmobiRabbitmqExtension());
        $container->register('cmobi_rabbitmq.pub_sub.test')
            ->setPublic(false);
        $container->register('cmobi_rabbitmq.connection.default')
            ->setPublic(false);
    }

    protected function process(ContainerBuilder $container)
    {
        $subscriberPass = new SubscriberPass(
            'exchange_test',
            ExchangeType::FANOUT,
            'test',
            'cmobi_rabbitmq.connection.default',
            'cmobi_rabbitmq.message.handler',
            1,
            []
        );
        $subscriberPass->process($container);
    }
}