Puzzle\AMQP\Clients\Decorators\PrefixedExchangesClient

Complexity

Total Complexity

7

Size/Duplication

Total Lines	57
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

91.67%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	5	5	1
A	publish()	7	7	1
A	computeExchangeName()	14	14	2
A	getQueue()	4	4	1
A	getExchange()	6	6	1
A	appendMessageProcessor()	4	4	1

<?php

namespace Puzzle\AMQP\Clients\Decorators;

use Puzzle\AMQP\Client;
use Puzzle\AMQP\WritableMessage;
use Psr\Log\LoggerAwareTrait;
use Puzzle\AMQP\Messages\Processor;

class PrefixedExchangesClient implements Client

This class seems to be duplicated in your project.

{
    const
        DELIMITER = '.';
    
    use LoggerAwareTrait;
    
    private
        $client,
        $exchangesPrefix;
    
    public function __construct(Client $client, $exchangesPrefix)
    {
        $this->client = $client;
        $this->exchangesPrefix = $exchangesPrefix;
    }
    
    public function publish($exchangeName, WritableMessage $message)
    {
        return $this->client->publish(
            $this->computeExchangeName($exchangeName),
            $message
        );
    }
    
    private function computeExchangeName($exchangeName)
    {
        $exchangeParts = [];
        
        if(! empty($this->exchangesPrefix))
        {
            $exchangeParts[] = trim($this->exchangesPrefix);
        }

        $exchangeParts[] = $exchangeName;
        
        return trim(implode(self::DELIMITER, $exchangeParts));
            
    }
    
    public function getQueue($queueName)
    {
        return $this->client->getQueue($queueName);
    }
    
    public function getExchange($exchangeName)
    {
        return $this->client->getExchange(
            $this->computeExchangeName($exchangeName)
        );
    }

    public function appendMessageProcessor(Processor $processor)
    {
        return $this->client->addMessageProcessor($processor);

The method addMessageProcessor() does not seem to exist on object<Puzzle\AMQP\Client>.

    }
}