Darkilliant\MqProcessBundle\Message\Provider\MessageProviderFactory::factory()

Complexity

Conditions	3
Paths	3

Size

Total Lines	20
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

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

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

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

        return null;
    }