Innmind\AMQP\Client\Channel\Channel

Complexity

Total Complexity

9

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	closed()	0	3	2
A	basic()	0	3	1
A	exchange()	0	3	1
A	transaction()	0	3	1
A	queue()	0	3	1
A	__construct()	0	13	1
A	close()	0	14	2

<?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;
    }
}