AMQPAL\Adapter\AMQP\ConsumerCallbackTest

Complexity

Total Complexity

2

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	testGetDefaultMessageMapper()	0	16	1
A	testInvoke()	0	20	1

<?php

namespace AMQPAL\Adapter\AMQP;

use AMQPAL\Adapter\ConsumerInterface;
use AMQPAL\Adapter\Message;

class ConsumerCallbackTest extends \PHPUnit_Framework_TestCase
{
    public function testGetDefaultMessageMapper()
    {
        $callable = function () {
            
        };
        $queue = $this->prophesize(Queue::class);

        $consumerCallback = new ConsumerCallback($callable, $queue->reveal());

        static::assertInstanceOf(MessageMapper::class, $consumerCallback->getMessageMapper());

        $messageMapper = $this->prophesize(MessageMapper::class);
        $consumerCallback->setMessageMapper($messageMapper->reveal());

        static::assertSame($messageMapper->reveal(), $consumerCallback->getMessageMapper());
    }

    public function testInvoke()
    {
        $queue = $this->prophesize(Queue::class);
        $callable = $this->prophesize(ConsumerInterface::class);
        $libMessage = $this->prophesize(\AMQPEnvelope::class);
        $message = $this->prophesize(Message::class);
        $messageMapper = $this->prophesize(MessageMapper::class);

        $messageMapper->toMessage($libMessage->reveal())
            ->shouldBeCalled()
            ->willReturn($message);

        $callable->__invoke($message->reveal(), $queue->reveal())
            ->shouldBeCalled();

        $consumerCallback = new ConsumerCallback($callable->reveal(), $queue->reveal());
        $consumerCallback->setMessageMapper($messageMapper->reveal());

        $consumerCallback($libMessage->reveal());
    }
}