Cmobi\RabbitmqBundle\DependencyInjection\Compiler\WorkerPass

Complexity

Total Complexity

4

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

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

<?php

namespace Cmobi\RabbitmqBundle\DependencyInjection\Compiler;

use Cmobi\RabbitmqBundle\Queue\Queue;
use Cmobi\RabbitmqBundle\Transport\Worker\WorkerQueueBag;
use Cmobi\RabbitmqBundle\Transport\Worker\WorkerQueueCallback;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;

class WorkerPass implements CompilerPassInterface
{
    private $queueName;
    private $connectionName;
    private $serviceName;
    private $basicQos;
    private $arguments;
    private $jobs;

    public function __construct(
        $queueName,
        $connectionName,
        $serviceName,
        $basicQos,
        array $arguments,
        $jobs = 1
    )
    {
        $this->queueName = $queueName;
        $this->connectionName = $connectionName;
        $this->serviceName = $serviceName;
        $this->basicQos = $basicQos;
        $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.worker');
            $jobName = sprintf('cmobi_rabbitmq.worker.%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');
        $logger = $container->getDefinition('cmobi_rabbitmq.logger');
        $serviceDefinition = $container->getDefinition($this->serviceName);
        $queueBagDefinition = new Definition(
            WorkerQueueBag::class,
            [
                'queueName' => $this->queueName,
                'basicQos' => $this->basicQos,
                'arguments' => $this->arguments
            ]
        );
        $queueCallbackDefinition = new Definition(
            WorkerQueueCallback::class,
            [
                'queueService' => $serviceDefinition
            ]
        );
        $definition = new Definition(
            Queue::class,
            [
                'connectionManager' => $connection,
                'queueBag' => $queueBagDefinition,
                'logger' => $logger,
                'connectionName' => $this->connectionName,
                'callback' => $queueCallbackDefinition
            ]
        );

        return $definition;
    }
}