AmqpAdapterTest

Complexity

Total Complexity

10

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

4 Methods

Rating	Name	Duplication	Size	Complexity
B	setUp()	0	36	3
B	testPushAndReceive()	0	33	2
A	testPerf()	0	11	2
A	tearDown()	0	10	3

<?php

use Heri\Bundle\JobQueueBundle\Tests\TestCase;
use Heri\Bundle\JobQueueBundle\Adapter as Adapter;
use Heri\Bundle\JobQueueBundle\Service\QueueService;
use Heri\Bundle\JobQueueBundle\Command\QueueListenCommand;
use Symfony\Bundle\FrameworkBundle\Console\Application;
use Symfony\Component\Console\Output\ConsoleOutput;

class AmqpAdapterTest extends TestCase
{
    /**
     * @var QueueService
     */
    protected $queue;

    /**
     * @var string
     */
    protected $queueName = 'my:queue';

    /**
     * @var int
     */
    protected $maxMessages = 1;

    /**
     * @var AMQPConnection
     */
    protected $connection;

    /**
     * @var AMQPChannel
     */
    protected $channel;

    /**
     * @var bool
     */
    protected $verbose = true;

    /**
     * {@inheritdoc}
     */
    public function setUp()
    {
        parent::setUp();

        if (!class_exists('PhpAmqpLib\Message\AMQPMessage')) {
            $this->markTestSkipped('AMQP not installed');
        }

        // set default rabbitmq configuration
        $adapter = new Adapter\AmqpAdapter(array(
            'host' => 'localhost',
            'port' => '5672',
            'user' => 'guest',
            'password' => 'guest',
        ));

        $this->queue = new QueueService(
            $this->container->get('logger'),
            $this->container->getParameter('jobqueue.config')
        );
        $this->queue->adapter = $adapter;
        $this->queue->attach($this->queueName.'1');

        $application = new Application($this->kernel);
        $application->add(new QueueListenCommand());

        $command = $application->find('jobqueue:listen');
        $this->queue->setCommand($command);

$command of type object<Symfony\Component\Console\Command\Command> is not a sub-type of object<Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand>. It seems like you assume a child class of the class Symfony\Component\Console\Command\Command to be always present.

        if ($this->verbose) {
            $this->queue->setOutput(new ConsoleOutput());
        }

        $this->channel = $adapter->getChannel();

It seems like $adapter->getChannel() of type object<PhpAmqpLib\Connection\AMQPConnection> is incompatible with the declared type object<AMQPChannel> of property $channel.

        $this->connection = $adapter->getConnection();

It seems like $adapter->getConnection() of type object<PhpAmqpLib\Connection\AMQPConnection> is incompatible with the declared type object<AMQPConnection> of property $connection.

    }

    public function testPushAndReceive()
    {
        // Queue list command
        $command1 = array(
            'command' => 'list',
        );
        $this->queue->push($command1);

        // Queue demo:great command
        $command2 = [
            'command' => 'demo:great',
            'argument' => [
                'name' => 'Alexandre',
                '--yell' => true,
            ],
        ];
        $this->queue->push($command2);

        // Run list command using directly receive method
        $this->queue->receive($this->maxMessages);

        // Run demo:great command using listen method
        try {
            $this->queue->listen($this->queueName.'1');
            // $this->queue->receive($this->maxMessages);
        } catch (\Exception $e) {
            $this->assertRegExp(
                '/There are no commands defined in the "demo" namespace/',
                $e->getMessage(),
                'Command not found'
            );
        }
    }

    public function testPerf()
    {
        for ($i = 0; $i < 100; $i++) {
            // Queue list command
            $command = [
                'command' => 'list',
            ];
            $this->queue->push($command);
            $this->queue->receive(10);
        }
    }

    public function tearDown()
    {
        if ($this->channel) {
            $this->channel->queue_delete($this->queueName.'1');
            $this->channel->close();
        }
        if ($this->connection) {
            $this->connection->close();
        }
    }
}