Innmind\AMQP\Client\Channel\Basic\Logger

Complexity

Total Complexity

9

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	ack()	0	6	1
A	cancel()	0	6	1
A	consume()	0	7	1
A	get()	0	7	1
A	publish()	0	6	1
A	qos()	0	6	1
A	recover()	0	6	1
A	reject()	0	6	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client\Channel\Basic;

use Innmind\AMQP\{
    Client\Channel\Basic as BasicInterface,
    Model\Basic\Ack,
    Model\Basic\Cancel,
    Model\Basic\Consume,
    Model\Basic\Get as GetCommand,
    Model\Basic\Publish,
    Model\Basic\Qos,
    Model\Basic\Recover,
    Model\Basic\Reject,
    Model\Basic\Message
};
use Psr\Log\LoggerInterface;

final class Logger implements BasicInterface
{
    private $basic;
    private $logger;

    public function __construct(BasicInterface $basic, LoggerInterface $logger)
    {
        $this->basic = $basic;
        $this->logger = $logger;
    }

    public function ack(Ack $command): BasicInterface
    {
        $this->basic->ack($command);

        return $this;
    }

    public function cancel(Cancel $command): BasicInterface
    {
        $this->basic->cancel($command);

        return $this;
    }

    public function consume(Consume $command): Consumer
    {
        return new Consumer\Logger(
            $this->basic->consume($command),
            $this->logger
        );
    }

    public function get(GetCommand $command): Get
    {
        return new Get\Logger(
            $this->basic->get($command),
            $this->logger
        );
    }

    public function publish(Publish $command): BasicInterface
    {
        $this->basic->publish($command);

        return $this;
    }

    public function qos(Qos $command): BasicInterface
    {
        $this->basic->qos($command);

        return $this;
    }

    public function recover(Recover $command): BasicInterface
    {
        $this->basic->recover($command);

        return $this;
    }

    public function reject(Reject $command): BasicInterface
    {
        $this->basic->reject($command);

        return $this;
    }
}