OldSound\RabbitMqBundle\RabbitMq\DynamicConsumer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	mergeQueueOptions()	0	6	2
A	setQueueOptionsProvider()	0	4	1
A	setContext()	0	3	1
A	setupConsumer()	0	4	1

<?php

namespace OldSound\RabbitMqBundle\RabbitMq;

use OldSound\RabbitMqBundle\Provider\QueueOptionsProviderInterface;

class DynamicConsumer extends Consumer
{
    /**
     * Queue provider
     *
     * @var QueueOptionsProviderInterface
     */
    protected $queueOptionsProvider = null;

    /**
     * Context the consumer runs in
     *
     * @var string
     */
    protected $context = null;

    /**
     * QueueOptionsProvider setter
     *
     * @param QueueOptionsProviderInterface $queueOptionsProvider
     *
     * @return self
     */
    public function setQueueOptionsProvider(QueueOptionsProviderInterface $queueOptionsProvider)
    {
        $this->queueOptionsProvider = $queueOptionsProvider;
        return $this;
    }

    public function setContext($context)
    {
        $this->context = $context;
    }


    protected function setupConsumer()
    {
        $this->mergeQueueOptions();
        parent::setupConsumer();
    }

    protected function mergeQueueOptions()
    {
        if (null === $this->queueOptionsProvider) {
            return;
        }
        $this->queueOptions = array_merge($this->queueOptions, $this->queueOptionsProvider->getQueueOptions($this->context));
    }
}