Dtc\QueueBundle\Model\Worker

Complexity

Total Complexity

11

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

7.14%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getJobClass()	0	4	1
A	setJobClass()	0	4	1
A	getJobManager()	0	4	1
	getName()	0	1	?
A	setJobManager()	0	4	1
A	at()	0	15	3
A	later()	0	4	1
A	batchOrLaterDelay()	0	7	1
A	batchLater()	0	4	1
A	batchAt()	0	4	1

<?php

namespace Dtc\QueueBundle\Model;

abstract class Worker
{
    protected $jobManager;
    protected $jobClass;
    protected $job;

    /**
     * @return string
     */
    public function getJobClass()
    {
        return $this->jobClass;
    }

    /**
     * @param string $jobClass
     */
    public function setJobClass($jobClass)
    {
        $this->jobClass = $jobClass;
    }

    /**
     * @param JobManagerInterface $jobManager
     */
    public function setJobManager(JobManagerInterface $jobManager)
    {
        $this->jobManager = $jobManager;
    }

    /**
     * @return
     */
    public function getJobManager()
    {
        return $this->jobManager;
    }

    /**
     * @param int|null $time
     * @param bool     $batch
     * @param int|null $priority
     */
    public function at($time = null, $batch = false, $priority = null)
    {
        if (null === $time) {
            $time = time();
        }

        if ($time) {
            $dateTime = new \DateTime();
            $dateTime->setTimestamp($time);
        } else {
            $dateTime = null;
        }

        return new $this->jobClass($this, $batch, $priority, $dateTime);
    }

    /**
     * @param int      $delay    Amount of time to delay
     * @param int|null $priority
     */
    public function later($delay = 0, $priority = null)
    {
        return $this->batchOrLaterDelay($delay, false, $priority);
    }

    public function batchOrLaterDelay($delay = 0, $batch = false, $priority = null)
    {
        $job = $this->at(time() + $delay, $batch, $priority);
        $job->setDelay($delay);

        return $job;
    }

    /**
     * @param int      $delay    Amount of time to delay
     * @param int|null $priority
     */
    public function batchLater($delay = 0, $priority = null)
    {
        return $this->batchOrLaterDelay($delay, true, $priority);
    }

    /**
     * @param int|null $time
     * @param int|null $priority
     */
    public function batchAt($time = null, $priority = null)
    {
        return $this->at($time, true, $priority);
    }

    abstract public function getName();
}