OldSound\RabbitMqBundle\RabbitMq\GroupConsumer

Complexity

Total Complexity

10

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	addConsumers()	0	6	2
A	setupConsumer()	0	4	2
A	stopConsuming()	0	4	2
A	purge()	0	4	2
A	delete()	0	4	2

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