Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnection

Complexity

Total Complexity

3

Size/Duplication

Total Lines	23
Duplicated Lines	95.65 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	channel()	12	12	3

<?php

namespace Cmobi\RabbitmqBundle\Connection;

use PhpAmqpLib\Connection\AMQPStreamConnection;

class CmobiAMQPConnection extends AMQPStreamConnection implements CmobiAMQPConnectionInterface

This class seems to be duplicated in your project.

{
    /**
     * Fetches a channel object identified by the numeric channel_id, or
     * create that object if it doesn't already exist.
     *
     * @param string $channel_id
     *
     * @return CmobiAMQPChannel
     */
    public function channel($channel_id = null)
    {
        if (isset($this->channels[$channel_id])) {
            return $this->channels[$channel_id];
        }

        $channel_id = $channel_id ? $channel_id : $this->get_free_channel_id();
        $ch = new CmobiAMQPChannel($this->connection, $channel_id);
        $this->channels[$channel_id] = $ch;

        return $ch;
    }
}