Consumer::__construct() - Code Metrics - Inspection of "More test updates" - ccovey/rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (d6c481)

by Cody

created 2016-11-25 02:24 UTC

Consumer::__construct() A

↳ Parent: Consumer

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	6
ccs	5
cts	5
cp	1
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	4
nc	1
nop	3
crap	1

<?php

namespace Ccovey\RabbitMQ\Consumer;

use Ccovey\RabbitMQ\ChannelInterface;
use Ccovey\RabbitMQ\Connection\ConnectionInterface;
use Ccovey\RabbitMQ\QueuedMessage;
use Ccovey\RabbitMQ\QueueRestartManagerInterface;
use PhpAmqpLib\Message\AMQPMessage;

class Consumer implements ConsumerInterface
{
    /**
     * @var ConnectionInterface
     */
    private $connection;

    /**
     * @var QueueRestartManagerInterface
     */
    private $queueRestartManager;

    /**
     * @var ChannelInterface
     */
    private $channel;

    /**
     * @var callable
     */
    private $callback;

    public function __construct(ConnectionInterface $connection, QueueRestartManagerInterface $queueRestartManager, string $channelId = '')
    {
        $this->connection = $connection;
        $this->queueRestartManager = $queueRestartManager;
        $this->channel = $this->connection->getChannel($channelId);
    }

    public function setCallback(callable $callback)
    {
        $this->callback = $callback;
    }

    public function consume(Consumable $consumable)
    {
        $consumable->setCallback([$this, 'process']);
        $this->channel->consume($consumable);

        while (count($this->channel->getCallbacks())) {
            $this->channel->wait();
        }
    }

    protected function process(AMQPMessage $message)
    {
        $queuedMessage = new QueuedMessage($message);

        call_user_func($this->callback, $queuedMessage);

        $this->queueRestartManager->shouldRestart($queuedMessage->getQueueName());
    }
}


1		<?php
2
3		namespace Ccovey\RabbitMQ\Consumer;
4
5		use Ccovey\RabbitMQ\ChannelInterface;
6		use Ccovey\RabbitMQ\Connection\ConnectionInterface;
7		use Ccovey\RabbitMQ\QueuedMessage;
8		use Ccovey\RabbitMQ\QueueRestartManagerInterface;
9		use PhpAmqpLib\Message\AMQPMessage;
10
11		class Consumer implements ConsumerInterface
12		{
13		/**
14		* @var ConnectionInterface
15		*/
16		private $connection;
17
18		/**
19		* @var QueueRestartManagerInterface
20		*/
21		private $queueRestartManager;
22
23		/**
24		* @var ChannelInterface
25		*/
26		private $channel;
27
28		/**
29		* @var callable
30		*/
31		private $callback;
32
33	1	public function __construct(ConnectionInterface $connection, QueueRestartManagerInterface $queueRestartManager, string $channelId = '')
34		{
35	1	$this->connection = $connection;
36	1	$this->queueRestartManager = $queueRestartManager;
37	1	$this->channel = $this->connection->getChannel($channelId);
38	1	}
39
40		public function setCallback(callable $callback)
41		{
42		$this->callback = $callback;
43		}
44
45	1	public function consume(Consumable $consumable)
46		{
47	1	$consumable->setCallback([$this, 'process']);
48	1	$this->channel->consume($consumable);
49
50	1	while (count($this->channel->getCallbacks())) {
51	1	$this->channel->wait();
52		}
53	1	}
54
55		protected function process(AMQPMessage $message)
56		{
57		$queuedMessage = new QueuedMessage($message);
58
59		call_user_func($this->callback, $queuedMessage);
60
61		$this->queueRestartManager->shouldRestart($queuedMessage->getQueueName());
62		}
63		}
64

ccovey / rabbitmq

Branch — master (d6c481)

Consumer::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like