Glooby\TaskBundle\Queue\QueueMonitor

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setDoctrine()	0	4	1
A	setTaskManager()	0	4	1
A	monitor()	0	13	3

<?php

namespace Glooby\TaskBundle\Queue;

use Doctrine\Common\Persistence\ManagerRegistry;
use Glooby\TaskBundle\Manager\TaskManager;

/**
 * @author Emil Kilhage
 */
class QueueMonitor
{
    /**
     * @var ManagerRegistry
     */
    protected $doctrine;

    /**
     * @param ManagerRegistry $doctrine
     */
    public function setDoctrine($doctrine)
    {
        $this->doctrine = $doctrine;
    }

    /**
     * @var TaskManager
     */
    private $taskManager;

    /**
     * @param TaskManager $taskManager
     */
    public function setTaskManager(TaskManager $taskManager)
    {
        $this->taskManager = $taskManager;
    }

    /**
     *
     */
    public function monitor()
    {
        $taskRepo = $this->doctrine->getManager()
            ->getRepository('GloobyTaskBundle:QueuedTask');

        foreach ($taskRepo->findRunning() as $task) {
            if (false === posix_getpgid($task->getPId())) {
                $this->taskManager->failure($task, 'crashed');
            }
        }

        $this->doctrine->getManager()->flush();
    }
}