Innmind\AMQPBundle\DependencyInjection\InnmindAMQPExtension::load()

Complexity

Conditions	5
Paths	16

Size

Total Lines	52
Code Lines	33

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	32
CRAP Score	5.0006

Importance

Changes

0

<?php
    public function load(array $configs, ContainerBuilder $container)
    {
        $loader = new Loader\YamlFileLoader(
            $container,
            new FileLocator(__DIR__.'/../Resources/config')
        );
        $loader->load('services.yml');
        $config = $this->processConfiguration(
            new Configuration,
            $configs
        );

        $container
            ->getDefinition('innmind.amqp.connection.default')
            ->replaceArgument(1, $config['server'])
            ->replaceArgument(3, $config['server']['timeout'])
            ->replaceArgument(4, new Reference($config['clock']));

        $definition = $container->getDefinition('innmind.amqp.argument_translator');

        foreach ($config['argument_translators'] as $translator) {
            $definition->addArgument(new Reference($translator));
        }

        $autoDeclare = $container->getDefinition('innmind.amqp.client.auto_declare');
        $consumers = $container->getDefinition('innmind.amqp.consumers');

        foreach ($config['exchanges'] as $name => $exchange) {
            $autoDeclare->addMethodCall(
                'declareExchange',
                [$name, $exchange['type'], $exchange['durable'], $exchange['arguments']]
            );
        }

        foreach ($config['queues'] as $name => $queue) {
            $autoDeclare->addMethodCall(
                'declareQueue',
                [$name, $queue['durable'], $queue['exclusive'], $queue['arguments']]
            );
            $consumers->addMethodCall(
                'add',
                [$name, new Reference($queue['consumer'])]
            );
        }

        foreach ($config['bindings'] as $binding) {
            $autoDeclare->addMethodCall(
                'declareBinding',
                [$binding['exchange'], $binding['queue'], $binding['routingKey'], $binding['arguments']]
            );
        }
    }
}