AMQPAL\Adapter\AMQP\ConsumerCallbackTest::testInvoke()

Complexity

Conditions	1
Paths	1

Size

Total Lines	20
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    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());
    }
}