for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Cmobi\RabbitmqBundle\Connection;
use Cmobi\RabbitmqBundle\Connection\Exception\NotFoundAMQPConnectionFactoryException;
use Symfony\Component\DependencyInjection\ContainerAwareTrait;
class ConnectionManager
{
use ContainerAwareTrait;
private $factories;
public function __construct(array $factories)
$this->factories = $factories;
}
public function getConnection($name = null)
$factory = $this->getContainer()->get($this->factories['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();
/**
* @return \Symfony\Component\DependencyInjection\ContainerInterface
*/
public function getContainer()
return $this->container;
contamobi /
CmobiRabbitmqBundle
