DynamicConsumer::setupConsumer() - Code Metrics - php-amqplib/RabbitMqBundle - Measure and Improve Code Quality continuously with Scrutinizer

DynamicConsumer::setupConsumer() A
last analyzed 2025-08-03 22:43 UTC

↳ Parent: DynamicConsumer

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes	2
Bugs	0	Features	2

Metric	Value
cc	1
eloc	2
nc	1
nop	0
dl	0
loc	4
ccs	3
cts	3
cp	1
crap	1
rs	10
c	2
b	0
f	2

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


1		<?php
2
3		namespace OldSound\RabbitMqBundle\RabbitMq;
4
5		use OldSound\RabbitMqBundle\Provider\QueueOptionsProviderInterface;
6
7		class DynamicConsumer extends Consumer
8		{
9		/**
10		* Queue provider
11		*
12		* @var QueueOptionsProviderInterface
13		*/
14		protected $queueOptionsProvider = null;
15
16		/**
17		* Context the consumer runs in
18		*
19		* @var string
20		*/
21		protected $context = null;
22
23		/**
24		* QueueOptionsProvider setter
25		*
26		* @param QueueOptionsProviderInterface $queueOptionsProvider
27		*
28		* @return self
29		*/
30	1	public function setQueueOptionsProvider(QueueOptionsProviderInterface $queueOptionsProvider)
31		{
32	1	$this->queueOptionsProvider = $queueOptionsProvider;
33	1	return $this;
34		}
35
36	1	public function setContext($context)
37		{
38	1	$this->context = $context;
39	1	}
40
41
42	9	protected function setupConsumer()
43		{
44	9	$this->mergeQueueOptions();
45	9	parent::setupConsumer();
46	9	}
47
48	10	protected function mergeQueueOptions()
49		{
50	10	if (null === $this->queueOptionsProvider) {
51	9	return;
52		}
53	1	$this->queueOptions = array_merge($this->queueOptions, $this->queueOptionsProvider->getQueueOptions($this->context));
54	1	}
55		}
56

php-amqplib / RabbitMqBundle

DynamicConsumer::setupConsumer() A last analyzed 2025-08-03 22:43 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

DynamicConsumer::setupConsumer() A
last analyzed 2025-08-03 22:43 UTC