Noitran\Lumen\Horizon\Tests\RabbitMQQueueTest

Complexity

Total Complexity

1

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	testShouldSendExpectedMessageOnPushRaw()	0	46	1

<?php

namespace Noitran\Lumen\Horizon\Tests;

use Interop\Amqp\AmqpTopic;
use Interop\Amqp\AmqpQueue;
use Interop\Amqp\AmqpProducer;


class RabbitMQQueueTest extends TestCase
{
    public function testShouldSendExpectedMessageOnPushRaw()
    {
        $expectedQueueName = 'theQueueName';
        $expectedBody = 'thePayload';
        $topic = $this->createMock(AmqpTopic::class);
        $queue = $this->createMock(AmqpQueue::class);
        $queue->expects($this->any())->method('getQueueName')->willReturn('theQueueName');
        $producer = $this->createMock(AmqpProducer::class);
        $producer
            ->expects($this->once())
            ->method('send')
            ->with($this->identicalTo($topic), $this->isInstanceOf(AmqpMessage::class))

The type Noitran\Lumen\Horizon\Tests\AmqpMessage was not found. Maybe you did not declare it correctly or list all dependencies?

            ->willReturnCallback(function ($actualTopic, AmqpMessage $message) use ($expectedQueueName, $expectedBody, $topic) {
                $this->assertSame($topic, $actualTopic);
                $this->assertSame($expectedBody, $message->getBody());
                $this->assertSame($expectedQueueName, $message->getRoutingKey());
                $this->assertSame('application/json', $message->getContentType());
                $this->assertSame(AmqpMessage::DELIVERY_MODE_PERSISTENT, $message->getDeliveryMode());
                $this->assertNotEmpty($message->getCorrelationId());
                $this->assertNull($message->getProperty(RabbitMQJob::ATTEMPT_COUNT_HEADERS_KEY));

The type Noitran\Lumen\Horizon\Tests\RabbitMQJob was not found. Maybe you did not declare it correctly or list all dependencies?

            });
        $producer
            ->expects($this->never())
            ->method('setDeliveryDelay');
        $context = $this->createAmqpContext();

The method createAmqpContext() does not exist on Noitran\Lumen\Horizon\Tests\RabbitMQQueueTest.

        $context
            ->expects($this->once())
            ->method('createTopic')
            ->willReturn($topic);
        $context
            ->expects($this->once())
            ->method('createMessage')
            ->with($expectedBody)
            ->willReturn(new \Interop\Amqp\Impl\AmqpMessage($expectedBody));
        $context
            ->expects($this->once())
            ->method('createQueue')
            ->with($expectedQueueName)
            ->willReturn($queue);
        $context
            ->expects($this->once())
            ->method('createProducer')
            ->willReturn($producer);
        $queue = new RabbitMQQueue($context, $this->createDummyConfig());

The method createDummyConfig() does not exist on Noitran\Lumen\Horizon\Tests\RabbitMQQueueTest.

        $queue->setContainer($this->createDummyContainer());

The method createDummyContainer() does not exist on Noitran\Lumen\Horizon\Tests\RabbitMQQueueTest.

        $queue->pushRaw('thePayload', $expectedQueueName);
    }
}