Exchange::declare() - Code Metrics - Inspection of "add possibility to lock a message" - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — develop ( 13fd92...a71c17 )

by Baptiste

created 2017-09-10 10:00 UTC

Exchange::declare() A

↳ Parent: Exchange

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	8

Duplication

Lines	15
Ratio	100 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

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

<?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	2		public function __construct(Connection $connection, Channel $channel)
20			{
21	2		$this->connection = $connection;
22	2		$this->channel = $channel;
23	2		}
24
25		View Code Duplication	public function declare(Declaration $command): ExchangeInterface
26			{
27			$this->connection->send(
28			$this->connection->protocol()->exchange()->declare(
29			$this->channel,
30			$command
31			)
32			);
33
34			if ($command->shouldWait()) {
35			$this->connection->wait('exchange.declare-ok');
36			}
37
38			return $this;
39			}
40
41	1	View Code Duplication	public function delete(Deletion $command): ExchangeInterface
42			{
43	1		$this->connection->send(
44	1		$this->connection->protocol()->exchange()->delete(
45	1		$this->channel,
46	1		$command
47			)
48			);
49
50	1		if ($command->shouldWait()) {
51	1		$this->connection->wait('exchange.delete-ok');
52			}
53
54	1		return $this;
55			}
56			}
57

Innmind / AMQP

GitHub Access Token became invalid

Push — develop ( 13fd92...a71c17 )

Exchange::declare() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like