Shippinno\Job\Infrastructure\Ui\Console\Laravel\Command\JobConsume

Complexity

Total Complexity

7

Size/Duplication

Total Lines	53
Duplicated Lines	18.87 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

87.5%

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	10	10	2
B	handle()	0	17	5

<?php

namespace Shippinno\Job\Infrastructure\Ui\Console\Laravel\Command;

use Doctrine\Common\Persistence\ManagerRegistry;
use Illuminate\Console\Command;
use Interop\Queue\PsrContext;
use LogicException;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Shippinno\Job\Application\Messaging\ConsumeStoredJobService;
use Shippinno\Job\Domain\Model\JobRunnerNotRegisteredException;

class JobConsume extends Command
{
    use LoggerAwareTrait;

    /**
     * {@inheritdoc}
     */
    protected $signature = 'job:consume';

    /**
     * @var ConsumeStoredJobService
     */
    private $consumeStoredJobService;

    /**
     * @var ManagerRegistry|null
     */
    private $managerRegistry;

    /**
     * @param ConsumeStoredJobService $consumeStoredJobService
     * @param ManagerRegistry|null $managerRegistry
     * @param LoggerInterface|null $logger
     */
    public function __construct(

This method seems to be duplicated in your project.

        ConsumeStoredJobService $consumeStoredJobService,
        ManagerRegistry $managerRegistry = null,
        LoggerInterface $logger = null
    ) {
        parent::__construct();
        $this->consumeStoredJobService = $consumeStoredJobService;
        $this->managerRegistry = $managerRegistry;
        $this->setLogger(null !== $logger ? $logger : new NullLogger);
    }

    public function handle()
    {
        $queueName = env('JOB_CONSUME_QUEUE');
        if (!$queueName) {
            throw new LogicException('The env JOB_CONSUME_QUEUE is not defined');
        }
        $forever = !env('JOB_TESTING', false);
        do {
            if (null !== $this->managerRegistry) {
                $this->managerRegistry->getManager()->clear();
            }
            $this->consumeStoredJobService->execute($queueName);
            if (null !== $this->managerRegistry) {
                $this->managerRegistry->getManager()->flush();
            }
        } while ($forever);
    }
}