Exchange::declare() - Code Metrics - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Exchange::declare() A
last analyzed 2019-02-26 20:40 UTC

↳ Parent: Exchange

Complexity

Conditions	2
Paths	2

Size

Total Lines	14
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	2

Importance

Changes

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

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client\Channel\Exchange;

use Innmind\AMQP\{
    Client\Channel\Exchange as ExchangeInterface,
    Model\Exchange\Declaration,
    Model\Exchange\Deletion,
    Transport\Connection,
    Transport\Frame\Channel,
};

final class Exchange implements ExchangeInterface
{
    private $connection;
    private $channel;

    public function __construct(Connection $connection, Channel $channel)
    {
        $this->connection = $connection;
        $this->channel = $channel;
    }

    public function declare(Declaration $command): ExchangeInterface
    {
        $this->connection->send(
            $this->connection->protocol()->exchange()->declare(
                $this->channel,
                $command
            )
        );

        if ($command->shouldWait()) {
            $this->connection->wait('exchange.declare-ok');
        }

        return $this;
    }

    public function delete(Deletion $command): ExchangeInterface
    {
        $this->connection->send(
            $this->connection->protocol()->exchange()->delete(
                $this->channel,
                $command
            )
        );

        if ($command->shouldWait()) {
            $this->connection->wait('exchange.delete-ok');
        }

        return $this;
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\AMQP\Client\Channel\Exchange;
5
6		use Innmind\AMQP\{
7		Client\Channel\Exchange as ExchangeInterface,
8		Model\Exchange\Declaration,
9		Model\Exchange\Deletion,
10		Transport\Connection,
11		Transport\Frame\Channel,
12		};
13
14		final class Exchange implements ExchangeInterface
15		{
16		private $connection;
17		private $channel;
18
19	14	public function __construct(Connection $connection, Channel $channel)
20		{
21	14	$this->connection = $connection;
22	14	$this->channel = $channel;
23	14	}
24
25	2	public function declare(Declaration $command): ExchangeInterface
26		{
27	2	$this->connection->send(
28	2	$this->connection->protocol()->exchange()->declare(
29	2	$this->channel,
30	1	$command
31		)
32		);
33
34	2	if ($command->shouldWait()) {
35	2	$this->connection->wait('exchange.declare-ok');
36		}
37
38	2	return $this;
39		}
40
41	2	public function delete(Deletion $command): ExchangeInterface
42		{
43	2	$this->connection->send(
44	2	$this->connection->protocol()->exchange()->delete(
45	2	$this->channel,
46	1	$command
47		)
48		);
49
50	2	if ($command->shouldWait()) {
51	2	$this->connection->wait('exchange.delete-ok');
52		}
53
54	2	return $this;
55		}
56		}
57

Innmind / AMQP

GitHub Access Token became invalid

Exchange::declare() A last analyzed 2019-02-26 20:40 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Exchange::declare() A
last analyzed 2019-02-26 20:40 UTC