RabbitMqQueueCreator::createIfNecessary() - Code Metrics - phpservicebus/core - Measure and Improve Code Quality continuously with Scrutinizer

RabbitMqQueueCreator::createIfNecessary() A
last analyzed 2020-01-22 17:49 UTC

↳ Parent: RabbitMqQueueCreator

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	7
ccs	5
cts	5
cp	1
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	1
crap	2

<?php
namespace PSB\Core\Transport\RabbitMq;


use PSB\Core\Transport\QueueBindings;
use PSB\Core\Transport\QueueCreatorInterface;

class RabbitMqQueueCreator implements QueueCreatorInterface
{
    /**
     * @var BrokerModel
     */
    private $brokerModel;

    /**
     * @var RoutingTopology
     */
    private $routingTopology;

    /**
     * @var bool
     */
    private $useDurableMessages;

    /**
     * @param BrokerModel     $brokerModel
     * @param RoutingTopology $routingTopology
     * @param bool            $useDurableMessages
     */
    public function __construct(BrokerModel $brokerModel, RoutingTopology $routingTopology, $useDurableMessages)
    {
        $this->brokerModel = $brokerModel;
        $this->routingTopology = $routingTopology;
        $this->useDurableMessages = $useDurableMessages;
    }

    /**
     * Creates message queues for the defined queue bindings.
     *
     * @param QueueBindings $queueBindings
     */
    public function createIfNecessary(QueueBindings $queueBindings)
    {
        $addresses = array_merge($queueBindings->getReceivingAddresses(), $queueBindings->getSendingAddresses());
        foreach ($addresses as $address) {
            $this->routingTopology->setupForEndpointUse($this->brokerModel, $address);
        }
    }
}


1		<?php
2		namespace PSB\Core\Transport\RabbitMq;
3
4
5		use PSB\Core\Transport\QueueBindings;
6		use PSB\Core\Transport\QueueCreatorInterface;
7
8		class RabbitMqQueueCreator implements QueueCreatorInterface
9		{
10		/**
11		* @var BrokerModel
12		*/
13		private $brokerModel;
14
15		/**
16		* @var RoutingTopology
17		*/
18		private $routingTopology;
19
20		/**
21		* @var bool
22		*/
23		private $useDurableMessages;
24
25		/**
26		* @param BrokerModel $brokerModel
27		* @param RoutingTopology $routingTopology
28		* @param bool $useDurableMessages
29		*/
30	3	public function __construct(BrokerModel $brokerModel, RoutingTopology $routingTopology, $useDurableMessages)
31		{
32	3	$this->brokerModel = $brokerModel;
33	3	$this->routingTopology = $routingTopology;
34	3	$this->useDurableMessages = $useDurableMessages;
35	3	}
36
37		/**
38		* Creates message queues for the defined queue bindings.
39		*
40		* @param QueueBindings $queueBindings
41		*/
42	2	public function createIfNecessary(QueueBindings $queueBindings)
43		{
44	2	$addresses = array_merge($queueBindings->getReceivingAddresses(), $queueBindings->getSendingAddresses());
45	2	foreach ($addresses as $address) {
46	1	$this->routingTopology->setupForEndpointUse($this->brokerModel, $address);
47		}
48	2	}
49		}
50

phpservicebus / core

RabbitMqQueueCreator::createIfNecessary() A last analyzed 2020-01-22 17:49 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

RabbitMqQueueCreator::createIfNecessary() A
last analyzed 2020-01-22 17:49 UTC