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:16 UTC

Consumer::__construct() A

↳ Parent: Consumer

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	6
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	4
nc	1
nop	3

<?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			public function __construct(ConnectionInterface $connection, QueueRestartManagerInterface $queueRestartManager, string $channelId = '')
34			{
35			$this->connection = $connection;
36			$this->queueRestartManager = $queueRestartManager;
37			$this->channel = $this->connection->getChannel($channelId);
38			}
39
40			public function setCallback(callable $callback)
41			{
42			$this->callback = $callback;
43			}
44
45			public function consume(Consumable $consumable)
46			{
47			$consumable->setCallback([$this, 'process']);
48			$this->channel->consume($consumable);
49
50			while (count($this->channel->getCallbacks())) {
51			$this->channel->wait();
52			}
53			}
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

Importance

Duplication Side-by-Side

Filter issues like