AsyncJobDispatcher::__construct() - Code Metrics - cfrutos/async-jobs - Measure and Improve Code Quality continuously with Scrutinizer

AsyncJobDispatcher::__construct() A
last analyzed 2016-11-30 11:33 UTC

↳ Parent: AsyncJobDispatcher

Complexity

Conditions	1
Paths	1

Size

Total Lines	9
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	9
rs	9.6666
c	0
b	0
f	0
cc	1
eloc	6
nc	1
nop	1

<?php
namespace Workana\AsyncJobs\Dispatcher;

use DateTime;
use Bernard\Envelope;
use Workana\AsyncJobs\Job;
use Workana\AsyncJobs\JobManager;
use Workana\AsyncJobs\JobDispatcher;

/**
 * Job dispatcher on async mode
 *
 * @author Carlos Frutos <[email protected]>
 */
class AsyncJobDispatcher implements JobDispatcher
{
    /**
     * @var JobManager
     */
    protected $jm;

    /**
     * @var QueueDecider
     */
    protected $queueDecider;

    /**
     * Creates a new instance
     *
     * @param JobManager $jm
     */
    public function __construct(JobManager $jm)
    {
        $this->jm = $jm;
        $this->queueDecider = new QueueDecider(
            $jm->getQueueFactory(),
            $jm->getConfiguration()->getDefaultQueueName(),
            $jm->getConfiguration()->getDispatchingRules()
        );
    }

    /**
     * {@inheritDoc}
     */
    public function dispatch(Job $job)
    {
        $queue = $this->queueDecider->decide($job);
        
        $envelope = new Envelope($job, $job->getDelay());

        $queue->enqueue($envelope);
    }
}

1			<?php
2			namespace Workana\AsyncJobs\Dispatcher;
3
4			use DateTime;
5			use Bernard\Envelope;
6			use Workana\AsyncJobs\Job;
7			use Workana\AsyncJobs\JobManager;
8			use Workana\AsyncJobs\JobDispatcher;
9
10			/**
11			* Job dispatcher on async mode
12			*
13			* @author Carlos Frutos <[email protected]>
14			*/
15			class AsyncJobDispatcher implements JobDispatcher
16			{
17			/**
18			* @var JobManager
19			*/
20			protected $jm;
21
22			/**
23			* @var QueueDecider
24			*/
25			protected $queueDecider;
26
27			/**
28			* Creates a new instance
29			*
30			* @param JobManager $jm
31			*/
32			public function __construct(JobManager $jm)
33			{
34			$this->jm = $jm;
35			$this->queueDecider = new QueueDecider(
36			$jm->getQueueFactory(),
37			$jm->getConfiguration()->getDefaultQueueName(),
38			$jm->getConfiguration()->getDispatchingRules()
39			);
40			}
41
42			/**
43			* {@inheritDoc}
44			*/
45			public function dispatch(Job $job)
46			{
47			$queue = $this->queueDecider->decide($job);
48
49			$envelope = new Envelope($job, $job->getDelay());
50
51			$queue->enqueue($envelope);
52			}
53			}

cfrutos / async-jobs

AsyncJobDispatcher::__construct() A last analyzed 2016-11-30 11:33 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

AsyncJobDispatcher::__construct() A
last analyzed 2016-11-30 11:33 UTC