Darkilliant\MqProcessBundle\Message\Publisher\MessagePublisherFactory::factory()

Complexity

Conditions	3
Paths	3

Size

Total Lines	19
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function factory(string $name, array $config)
    {
        if (isset($this->messagePublisher[$name])) {
            return $this->messagePublisher[$name];
        }

        if ('amqp_lib' === $config['client']) {
            /** @var $connexion AMQPStreamConnection */
            $connexion = $this->container->get($config['connexion'] ?? 'darkilliant_mqprocess_connection');

            return $this->messagePublisher[$name] = new AmqpMessagePublisher(
                $connexion->channel(),
                $config['queue'],
                $config['exchange'],
                $config['persistant']
            );
        }

        return null;
    }