Cmobi\RabbitmqBundle\Connection\ConnectionManager

Complexity

Total Complexity

8

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getConnection()	0	16	4
A	setDefault()	0	4	1
A	getDefault()	0	4	1
A	getContainer()	0	4	1

<?php

namespace Cmobi\RabbitmqBundle\Connection;

use Cmobi\RabbitmqBundle\Connection\Exception\NotFoundAMQPConnectionFactoryException;
use Symfony\Component\DependencyInjection\ContainerAwareTrait;

class ConnectionManager
{
    use ContainerAwareTrait;

    private $factories;
    private $default;

    public function __construct(array $factories)
    {
        $this->default = 'default';
        $this->factories = $factories;
    }

    public function getConnection($name = null)
    {
        $factory = $this->getContainer()->get($this->factories[$this->default]);

        if (!is_null($name) && array_key_exists($name, $this->factories)) {
            $factory = $this->getContainer()->get(
                $this->factories[$name]
            );
        }

        if (!$factory instanceof ConnectionFactory) {
            throw new NotFoundAMQPConnectionFactoryException(sprintf('%s: connection not found.', $name));
        }

        return $factory->createConnection();
    }

    /**
     * @param $connName
     */
    public function setDefault($connName)
    {
        $this->default = $connName;
    }

    /**
     * @return string
     */
    public function getDefault()
    {
        return $this->default;
    }

    /**
     * @return \Symfony\Component\DependencyInjection\ContainerInterface
     */
    public function getContainer()
    {
        return $this->container;
    }
}