Puzzle\AMQP\Clients\Decorators\PrefixedQueuesClient

Complexity

Total Complexity

7

Size/Duplication

Total Lines	53
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

90.48%

Importance

Changes	1
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	5	5	1
A	publish()	4	4	1
A	getQueue()	6	6	1
A	getExchange()	4	4	1
A	computePrefixedQueueName()	13	13	2
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 PrefixedQueuesClient implements Client

This class seems to be duplicated in your project.

{
    const
        DELIMITER = '.';

    use LoggerAwareTrait;

    private
        $client,
        $queueNamePrefix;

    public function __construct(Client $client, $queueNamePrefix)
    {
        $this->client = $client;
        $this->queueNamePrefix = $queueNamePrefix;
    }

    public function publish($exchangeName, WritableMessage $message)
    {
        return $this->client->publish($exchangeName, $message);
    }

    public function getQueue($queueName)
    {
        $prefixedQueueName = $this->computePrefixedQueueName($queueName);

        return $this->client->getQueue($prefixedQueueName);
    }

    public function getExchange($exchangeName)
    {
        return $this->client->getExchange($exchangeName);
    }

    private function computePrefixedQueueName($queueName)
    {
        $queueNameParts = [];

        if(! empty($this->queueNamePrefix))
        {
            $queueNameParts[] = trim($this->queueNamePrefix);
        }

        $queueNameParts[] = $queueName;

        return implode(self::DELIMITER, $queueNameParts);
    }
    
    public function appendMessageProcessor(Processor $processor)
    {
        return $this->client->addMessageProcessor($processor);

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

    }
}