GroupConsumer::addConsumers() - Code Metrics - Inspection of "add rabbitmq:group:consumer command" - eMAGTechLabs/RabbitMqBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#38)

by Aleksandr

created 2020-11-18 20:45 UTC

GroupConsumer::addConsumers() A

↳ Parent: GroupConsumer

Complexity

Conditions	2
Paths	2

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

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

<?php

namespace OldSound\RabbitMqBundle\RabbitMq;

use PhpAmqpLib\Connection\AbstractConnection;
use Symfony\Component\Console\Exception\InvalidArgumentException;

class GroupConsumer extends Consumer
{
    /** @var iterable|Consumer[] */
    protected $consumers = [];

    public function addConsumers(iterable $consumers)
    {
        foreach ($consumers as $consumer) {
            $consumer->setChannel($this->ch);
            $consumer->setConsumerTag(sprintf("PHPPROCESS_%s_%s_%s", gethostname(), getmypid(), count($this->consumers)));
            $this->consumers[] = $consumer;
        }
    }

    protected function setupConsumer()
    {
        foreach ($this->consumers as $consumer) {
            $consumer->setupConsumer();
        }
    }

    public function stopConsuming()
    {
        foreach ($this->consumers as $consumer) {
            $consumer->stopConsuming();
        }
    }

    public function purge()
    {
        foreach ($this->consumers as $consumer) {
            $consumer->purge();
        }
    }

    public function delete()
    {
        foreach ($this->consumers as $consumer) {
            $consumer->delete();
        }
    }
}

1			<?php
2
3			namespace OldSound\RabbitMqBundle\RabbitMq;
4
5			use PhpAmqpLib\Connection\AbstractConnection;
6			use Symfony\Component\Console\Exception\InvalidArgumentException;
7
8			class GroupConsumer extends Consumer
9			{
10			/** @var iterable\|Consumer[] */
11			protected $consumers = [];
12
13			public function addConsumers(iterable $consumers)
14			{
15			foreach ($consumers as $consumer) {
16			$consumer->setChannel($this->ch);
17			$consumer->setConsumerTag(sprintf("PHPPROCESS_%s_%s_%s", gethostname(), getmypid(), count($this->consumers)));
18			$this->consumers[] = $consumer;
19			}
20			}
21
22			protected function setupConsumer()
23			{
24			foreach ($this->consumers as $consumer) {
25			$consumer->setupConsumer();
26			}
27			}
28
29			public function stopConsuming()
30			{
31			foreach ($this->consumers as $consumer) {
32			$consumer->stopConsuming();
33			}
34			}
35
36			public function purge()
37			{
38			foreach ($this->consumers as $consumer) {
39			$consumer->purge();
40			}
41			}
42
43			public function delete()
44			{
45			foreach ($this->consumers as $consumer) {
46			$consumer->delete();
47			}
48			}
49			}

eMAGTechLabs / RabbitMqBundle

Pull Request — master (#38)

GroupConsumer::addConsumers() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like