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

AmqpConnectionFactory::createConnection() A
last analyzed 2020-01-22 17:49 UTC

↳ Parent: AmqpConnectionFactory

Complexity

Conditions	3
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	13
ccs	7
cts	7
cp	1
rs	9.8333
c	0
b	0
f	0
cc	3
nc	3
nop	0
crap	3

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


use AMQPConnection;
use PSB\Core\Transport\TransportConnectionFactoryInterface;
use PSB\Core\Util\Settings;

class AmqpConnectionFactory implements TransportConnectionFactoryInterface
{
    /**
     * @var array
     */
    private $defaultCredentials = [
        'host' => '127.0.0.1',
        'port' => '5672',
        'vhost' => '/',
        'login' => 'guest',
        'password' => 'guest',
        'heartbeat' => 5
    ];

    /**
     * @var Settings
     */
    private $settings;

    /**
     * @param Settings $settings
     */
    public function __construct(Settings $settings)
    {
        $this->settings = $settings;
    }

    /**
     * @return AMQPConnection
     */
    public function createConnection()
    {
        /** @var AMQPConnection $connection */
        $connection = $this->settings->tryGet(RabbitMqKnownSettingsEnum::CONNECTION);

        if (!$connection) {
            $connectionCredentials = $this->settings->tryGet(RabbitMqKnownSettingsEnum::CONNECTION_CREDENTIALS) ?: [];
            $connectionCredentials = array_replace($this->defaultCredentials, $connectionCredentials);
            $connection = new AMQPConnection($connectionCredentials);
        }

        return $connection;
    }
}


1		<?php
2		namespace PSB\Core\Transport\RabbitMq;
3
4
5		use AMQPConnection;
6		use PSB\Core\Transport\TransportConnectionFactoryInterface;
7		use PSB\Core\Util\Settings;
8
9		class AmqpConnectionFactory implements TransportConnectionFactoryInterface
10		{
11		/**
12		* @var array
13		*/
14		private $defaultCredentials = [
15		'host' => '127.0.0.1',
16		'port' => '5672',
17		'vhost' => '/',
18		'login' => 'guest',
19		'password' => 'guest',
20		'heartbeat' => 5
21		];
22
23		/**
24		* @var Settings
25		*/
26		private $settings;
27
28		/**
29		* @param Settings $settings
30		*/
31	4	public function __construct(Settings $settings)
32		{
33	4	$this->settings = $settings;
34	4	}
35
36		/**
37		* @return AMQPConnection
38		*/
39	2	public function createConnection()
40		{
41		/** @var AMQPConnection $connection */
42	2	$connection = $this->settings->tryGet(RabbitMqKnownSettingsEnum::CONNECTION);
43
44	2	if (!$connection) {
45	1	$connectionCredentials = $this->settings->tryGet(RabbitMqKnownSettingsEnum::CONNECTION_CREDENTIALS) ?: [];
46	1	$connectionCredentials = array_replace($this->defaultCredentials, $connectionCredentials);
47	1	$connection = new AMQPConnection($connectionCredentials);
48		}
49
50	2	return $connection;
51		}
52		}
53

phpservicebus / core

AmqpConnectionFactory::createConnection() A last analyzed 2020-01-22 17:49 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

AmqpConnectionFactory::createConnection() A
last analyzed 2020-01-22 17:49 UTC