Innmind\AMQP\Transport\Protocol\v091\Protocol

Complexity

Total Complexity

9

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	1	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	version()	0	4	1
A	connection()	0	4	1
A	exchange()	0	4	1
A	queue()	0	4	1
A	basic()	0	4	1
A	transaction()	0	4	1
A	__construct()	0	11	1
A	channel()	0	4	1
A	read()	0	4	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Transport\Protocol\v091;

use Innmind\AMQP\Transport\{
    Protocol as ProtocolInterface,
    Protocol\Version,
    Protocol\Connection as ConnectionInterface,
    Protocol\Channel as ChannelInterface,
    Protocol\Exchange as ExchangeInterface,
    Protocol\Queue as QueueInterface,
    Protocol\Basic as BasicInterface,
    Protocol\Transaction as TransactionInterface,
    Frame\Method
};
use Innmind\Immutable\{
    Str,
    StreamInterface
};

final class Protocol implements ProtocolInterface
{
    private $version;
    private $read;
    private $connection;
    private $channel;
    private $exchange;
    private $queue;
    private $basic;
    private $transaction;

    public function __construct()
    {
        $this->version = new Version(0, 9, 1);
        $this->read = new Reader;
        $this->connection = new Connection;
        $this->channel = new Channel;
        $this->exchange = new Exchange;
        $this->queue = new Queue;
        $this->basic = new Basic;
        $this->transaction = new Transaction;
    }

    public function version(): Version
    {
        return $this->version;
    }

    /**
     * {@inheritdoc}
     */
    public function read(Method $method, Str $arguments): StreamInterface
    {
        return ($this->read)($method, $arguments);
    }

    public function connection(): ConnectionInterface
    {
        return $this->connection;
    }

    public function channel(): ChannelInterface
    {
        return $this->channel;
    }

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

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

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

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