OldSound\RabbitMqBundle\Declarations\ConsumerFactory::create()

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function create($name): Consumer
    {
        $consumerDef = $this->consumerDefs[$name];
        /** @var AbstractConnection $connection */
        $connection = $this->container->get(sprintf('old_sound_rabbit_mq.connection.%s', $consumerDef->name));
        $consumer = new Consumer($consumerDef->name);

$consumerDef->name of type string is incompatible with the type PhpAmqpLib\Channel\AMQPChannel expected by parameter $channel of OldSound\RabbitMqBundle\RabbitMq\Consumer::__construct().

        $consumer->setChannel($connection->channel());

The method setChannel() does not exist on OldSound\RabbitMqBundle\RabbitMq\Consumer.

        foreach([] as $d) {
            $consumer->consumeQueue();

The call to OldSound\RabbitMqBundle\RabbitMq\Consumer::consumeQueue() has too few arguments starting with consumerOptions.

        }

        return $consumer;
    }
}