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

Channel::queue() A
last analyzed 2019-02-26 20:40 UTC

↳ Parent: Channel

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

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

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client\Channel;

use Innmind\AMQP\{
    Client\Channel as ChannelInterfce,
    Model\Channel\Close,
    Transport\Connection,
    Transport\Frame\Channel as Number,
};

final class Channel implements ChannelInterfce
{
    private $connection;
    private $number;
    private $exchange;
    private $queue;
    private $basic;
    private $transaction;
    private $closed = false;

    public function __construct(Connection $connection, Number $number)
    {
        $this->connection = $connection;
        $this->number = $number;

        $connection
            ->send($connection->protocol()->channel()->open($number))
            ->wait('channel.open-ok');

        $this->exchange = new Exchange\Exchange($connection, $number);
        $this->queue = new Queue\Queue($connection, $number);
        $this->basic = new Basic\Basic($connection, $number);
        $this->transaction = new Transaction\Transaction($connection, $number);
    }

    public function exchange(): Exchange
    {
        return $this->exchange;
    }

    public function queue(): Queue
    {
        return $this->queue;
    }

    public function basic(): Basic
    {
        return $this->basic;
    }

    public function transaction(): Transaction
    {
        return $this->transaction;
    }

    public function closed(): bool
    {
        return $this->closed || $this->connection->closed();
    }

    public function close(): void
    {
        if ($this->closed()) {
            return;
        }

        $this
            ->connection
            ->send($this->connection->protocol()->channel()->close(
                $this->number,
                new Close
            ))
            ->wait('channel.close-ok');
        $this->closed = true;
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\AMQP\Client\Channel;
5
6		use Innmind\AMQP\{
7		Client\Channel as ChannelInterfce,
8		Model\Channel\Close,
9		Transport\Connection,
10		Transport\Frame\Channel as Number,
11		};
12
13		final class Channel implements ChannelInterfce
14		{
15		private $connection;
16		private $number;
17		private $exchange;
18		private $queue;
19		private $basic;
20		private $transaction;
21		private $closed = false;
22
23	8	public function __construct(Connection $connection, Number $number)
24		{
25	8	$this->connection = $connection;
26	8	$this->number = $number;
27
28		$connection
29	8	->send($connection->protocol()->channel()->open($number))
30	8	->wait('channel.open-ok');
31
32	8	$this->exchange = new Exchange\Exchange($connection, $number);
33	8	$this->queue = new Queue\Queue($connection, $number);
34	8	$this->basic = new Basic\Basic($connection, $number);
35	8	$this->transaction = new Transaction\Transaction($connection, $number);
36	8	}
37
38	2	public function exchange(): Exchange
39		{
40	2	return $this->exchange;
41		}
42
43	2	public function queue(): Queue
44		{
45	2	return $this->queue;
46		}
47
48	2	public function basic(): Basic
49		{
50	2	return $this->basic;
51		}
52
53	2	public function transaction(): Transaction
54		{
55	2	return $this->transaction;
56		}
57
58	6	public function closed(): bool
59		{
60	6	return $this->closed \|\| $this->connection->closed();
61		}
62
63	4	public function close(): void
64		{
65	4	if ($this->closed()) {
66	2	return;
67		}
68
69		$this
70	4	->connection
71	4	->send($this->connection->protocol()->channel()->close(
72	4	$this->number,
73	4	new Close
74		))
75	4	->wait('channel.close-ok');
76	4	$this->closed = true;
77	4	}
78		}
79

Innmind / AMQP

GitHub Access Token became invalid

Channel::queue() A last analyzed 2019-02-26 20:40 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Channel::queue() A
last analyzed 2019-02-26 20:40 UTC