Cmobi\RabbitmqBundle\Tests\Transport\Subscriber\PublisherTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	123
Duplicated Lines	61.79 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	testGetExchange()	0	11	1
A	testGetExchangeType()	11	11	1
A	testGetQueueName()	0	12	1
A	testGetFromName()	12	12	1
A	getConnectionManagerMock()	10	10	1
A	getConnectionMock()	14	14	1
A	getChannelMock()	15	15	1
A	getCmobiAMQPMessage()	13	13	1

<?php

namespace Cmobi\RabbitmqBundle\Tests\Transport\Subscriber;

use Cmobi\RabbitmqBundle\Connection\CmobiAMQPChannel;
use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnection;
use Cmobi\RabbitmqBundle\Connection\ConnectionManager;
use Cmobi\RabbitmqBundle\Queue\CmobiAMQPMessage;
use Cmobi\RabbitmqBundle\Tests\BaseTestCase;
use Cmobi\RabbitmqBundle\Transport\Subscriber\ExchangeType;
use Cmobi\RabbitmqBundle\Transport\Subscriber\Publisher;

class PublisherTest extends BaseTestCase
{
    public function testGetQueueName()
    {
        $publisher = new Publisher(
            'exch_test',
            ExchangeType::FANOUT,
            $this->getConnectionManagerMock(),
            'from_name_test',
            'test'
        );

        $this->assertEquals('test', $publisher->getQueueName());
    }

    public function testGetExchange()
    {
        $publisher = new Publisher(
            'exch_test',
            ExchangeType::FANOUT,
            $this->getConnectionManagerMock(),
            'test'
        );

        $this->assertEquals('exch_test', $publisher->getExchange());
    }

    public function testGetExchangeType()

This method seems to be duplicated in your project.

    {
        $publisher = new Publisher(
            'exch_test',
            ExchangeType::DIRECT,
            $this->getConnectionManagerMock(),
            'test'
        );

        $this->assertEquals(ExchangeType::DIRECT, $publisher->getExchangeType());
    }

    public function testGetFromName()

This method seems to be duplicated in your project.

    {
        $publisher = new Publisher(
            'exch_test',
            ExchangeType::FANOUT,
            $this->getConnectionManagerMock(),
            'caller_test',
            ''
        );

        $this->assertEquals('caller_test', $publisher->getFromName());
    }

    /**
     * @return ConnectionManager
     */
    protected function getConnectionManagerMock()

This method seems to be duplicated in your project.

    {
        $connectionManagerMock = $this->getMockBuilder(ConnectionManager::class)
            ->disableOriginalConstructor()
            ->getMock();
        $connectionManagerMock->method('getConnection')
            ->willReturn($this->getConnectionMock());

        return $connectionManagerMock;
    }

    /**
     * @return CmobiAMQPConnection
     */
    protected function getConnectionMock()

This method seems to be duplicated in your project.

    {
        $connectionMock = $this->getMockBuilder(CmobiAMQPConnection::class)
            ->disableOriginalConstructor()
            ->getMock();
        $connectionMock->method('isConnected')
            ->willReturn(true);
        $connectionMock->method('reconnect')
            ->willReturn(true);
        $connectionMock->method('channel')
            ->willReturn($this->getChannelMock());

        return $connectionMock;
    }

    /**
     * @return CmobiAMQPChannel
     */
    protected function getChannelMock()

This method seems to be duplicated in your project.

    {
        $channelMock = $this->getMockBuilder(CmobiAMQPChannel::class)
            ->disableOriginalConstructor()
            ->getMock();
        $channelMock
            ->expects($this->any())
            ->method('basic_publish')
            ->willReturn(true);
        $channelMock
            ->method('basicConsume')
            ->willReturn(true);

        return $channelMock;
    }

    /**
     * @param string $msg
     * @param null   $correlationId
     *
     * @return CmobiAMQPMessage
     */
    protected function getCmobiAMQPMessage($msg = '', $correlationId = null)

This method seems to be duplicated in your project.

    {
        $msgMock = $this->getMockBuilder(CmobiAMQPMessage::class)
            ->disableOriginalConstructor()
            ->getMock();
        $msgMock->method('get')
            ->willReturn('correlation_id')
            ->willReturn($correlationId);
        $msgMock->method('getBody')
            ->willReturn($msg);

        return $msgMock;
    }
}