Cmobi\RabbitmqBundle\DependencyInjection\Compiler\RpcServerPass

Complexity

Total Complexity

4

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	20	1
B	buildDefinition()	0	32	1
A	process()	0	9	2

<?php

namespace Cmobi\RabbitmqBundle\DependencyInjection\Compiler;

use Cmobi\RabbitmqBundle\Queue\Queue;
use Cmobi\RabbitmqBundle\Transport\Rpc\RpcQueueBag;
use Cmobi\RabbitmqBundle\Transport\Rpc\RpcQueueCallback;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;

class RpcServerPass implements CompilerPassInterface
{
    private $queueName;
    private $connectionName;
    private $serviceName;
    private $basicQos;
    private $durable;
    private $autoDelete;
    private $arguments;
    private $jobs;

    public function __construct(
        $queueName,
        $connectionName,
        $serviceName,
        $basicQos,
        $durable,
        $autoDelete,
        array $arguments,
        $jobs = 1
    )
    {
        $this->queueName = $queueName;
        $this->connectionName = $connectionName;
        $this->serviceName = $serviceName;
        $this->basicQos = $basicQos;
        $this->durable = $durable;
        $this->autoDelete = $autoDelete;
        $this->arguments = $arguments;
        $this->jobs = $jobs;
    }

    /**
     * @param ContainerBuilder $container
     * @throws \Exception
     */
    public function process(ContainerBuilder $container)
    {
        for ($job = 0; $job < $this->jobs; $job++) {
            $definition = $this->buildDefinition($container);
            $definition->addTag('cmobi.rpc_server');
            $jobName = sprintf('cmobi_rabbitmq.rpc_server.%s_%s', $this->queueName, $job);
            $container->setDefinition($jobName, $definition);
        }
    }

    /**
     * @param ContainerBuilder $container
     * @return Definition
     * @throws \Exception
     */
    protected function buildDefinition(ContainerBuilder $container)
    {
        $connection = $container->getDefinition('cmobi_rabbitmq.connection.manager');
        $serviceDefinition = $container->getDefinition($this->serviceName);
        $queueBagDefinition = new Definition(
            RpcQueueBag::class,
            [
                'queueName' => $this->queueName,
                'basicQos' => $this->basicQos,
                'durable' => $this->durable,
                'autoDelete' => $this->autoDelete,
                'arguments' => $this->arguments
            ]
        );
        $queueCallbackDefinition = new Definition(
            RpcQueueCallback::class,
            [
                'queueService' => $serviceDefinition
            ]
        );
        $definition = new Definition(
            Queue::class,
            [
                'connectionManager' => $connection,
                'queueBag' => $queueBagDefinition,
                'connectionName' => $this->connectionName,
                'callback' => $queueCallbackDefinition
            ]
        );

        return $definition;
    }
}