GroupConsumer::purge() - Code Metrics - Inspection of "Group consumer" - php-amqplib/RabbitMqBundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#631)

by Aleksandr

created 2021-03-28 17:54 UTC

GroupConsumer::purge() A

↳ Parent: GroupConsumer

Complexity

Conditions	2
Paths	2

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

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

<?php

namespace OldSound\RabbitMqBundle\RabbitMq;

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

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

    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;
        }
    }

    public 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();
        }
    }

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

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 = array();
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			public 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
50			public function disableAutoSetupFabric()
51			{
52			foreach ($this->consumers as $consumer) {
53			$consumer->disableAutoSetupFabric();
54			}
55			}
56			}

php-amqplib / RabbitMqBundle

Pull Request — master (#631)

GroupConsumer::purge() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like