MongoWorker::processJob() - Code Metrics - Inspection of "Task Scheduler" - cross-solution/YAWIK - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — develop (#533)

by Mathias

created 2019-02-08 16:23 UTC

MongoWorker::processJob() A

↳ Parent: MongoWorker

Complexity

Conditions	4
Paths	6

Size

Total Lines	21
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	4

Importance

Changes

Metric	Value
eloc	12
dl	0
loc	21
ccs	12
cts	12
cp	1
rs	9.8666
c	0
b	0
f	0
cc	4
nc	6
nop	2
crap	4

<?php
/**
 * YAWIK
 *
 * @filesource
 * @license MIT
 * @copyright  2013 - 2019 Cross Solution <http://cross-solution.de>
 */
  
/** */
namespace Core\Queue\Worker;

use Core\Queue\Exception\FatalJobException;
use Core\Queue\Exception\RecoverableJobException;
use Core\Queue\MongoQueue;
use SlmQueue\Job\JobInterface;
use SlmQueue\Queue\QueueInterface;
use SlmQueue\Worker\AbstractWorker;
use SlmQueue\Worker\Event\ProcessJobEvent;

/**
 * Queue worker for the mongo queue.
 *
 * @author Mathias Gelhausen <[email protected]>
 */
class MongoWorker extends AbstractWorker
{
    /**
     * Process job handler.
     *
     * @param JobInterface   $job
     * @param QueueInterface $queue
     *
     * @return int|void
     */
    public function processJob(JobInterface $job, QueueInterface $queue)
    {
        if (!$queue instanceof MongoQueue) {
            return;
        }

        try {
            $job->execute();
            $queue->delete($job);

            return ProcessJobEvent::JOB_STATUS_SUCCESS;

        } catch (RecoverableJobException $exception) {
            $queue->retry($job, $exception->getOptions());

            return ProcessJobEvent::JOB_STATUS_FAILURE_RECOVERABLE;

        } catch (FatalJobException $exception) {
            $queue->fail($job, $exception->getOptions());

            return ProcessJobEvent::JOB_STATUS_FAILURE;
        }
    }
}


1		<?php
2		/**
3		* YAWIK
4		*
5		* @filesource
6		* @license MIT
7		* @copyright 2013 - 2019 Cross Solution <http://cross-solution.de>
8		*/
9
10		/** */
11		namespace Core\Queue\Worker;
12
13		use Core\Queue\Exception\FatalJobException;
14		use Core\Queue\Exception\RecoverableJobException;
15		use Core\Queue\MongoQueue;
16		use SlmQueue\Job\JobInterface;
17		use SlmQueue\Queue\QueueInterface;
18		use SlmQueue\Worker\AbstractWorker;
19		use SlmQueue\Worker\Event\ProcessJobEvent;
20
21		/**
22		* Queue worker for the mongo queue.
23		*
24		* @author Mathias Gelhausen <[email protected]>
25		*/
26		class MongoWorker extends AbstractWorker
27		{
28		/**
29		* Process job handler.
30		*
31		* @param JobInterface $job
32		* @param QueueInterface $queue
33		*
34		* @return int\|void
35		*/
36	4	public function processJob(JobInterface $job, QueueInterface $queue)
37		{
38	4	if (!$queue instanceof MongoQueue) {
39	1	return;
40		}
41
42		try {
43	3	$job->execute();
44	1	$queue->delete($job);
45
46	1	return ProcessJobEvent::JOB_STATUS_SUCCESS;
47
48	2	} catch (RecoverableJobException $exception) {
49	1	$queue->retry($job, $exception->getOptions());
50
51	1	return ProcessJobEvent::JOB_STATUS_FAILURE_RECOVERABLE;
52
53	1	} catch (FatalJobException $exception) {
54	1	$queue->fail($job, $exception->getOptions());
55
56	1	return ProcessJobEvent::JOB_STATUS_FAILURE;
57		}
58		}
59		}
60

cross-solution / YAWIK

Pull Request — develop (#533)

MongoWorker::processJob() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like