OldSound\RabbitMqBundle\RabbitMq\GroupConsumer

Complexity

Total Complexity

4

Size/Duplication

Total Lines	18
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	addConsumers()	0	6	2
A	setupConsumer()	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();
        }
    }
}