Core\Queue\Worker\MongoWorker

Complexity

Total Complexity

4

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	processJob()	0	21	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 <gelhausen@cross-solution.de>
 */
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;
        }
    }
}