mmucklo / DtcQueueBundle

class JobManager extends BaseJobManager

{

    public function countJobsByStatus($objectName, $status, $workerName = null, $method = null)

    {

        /** @var DocumentManager $objectManager */

        $objectManager = $this->getObjectManager();

        $qb = $objectManager->createQueryBuilder($objectName);

        $qb

            ->find()

            ->field('status')->equals($status);

        $this->addWorkerNameCriterion($qb, $workerName, $method);

        $query = $qb->getQuery();

        return $query->count();

    }

    /**

     * @param string $objectName

     *

     * @return int Count of jobs pruned

     */

    protected function pruneJobs($workerName = null, $method = null, $objectName, $conditionFunc)

    {

        /** @var EntityManager $objectManager */

        $objectManager = $this->getObjectManager();

        $qb = $objectManager->createQueryBuilder()->delete($objectName, 'j');

        $conditionFunc($qb);

        $this->addWorkerNameCriterion($qb, $workerName, $method);

        $query = $qb->getQuery();

        return intval($query->execute());

    }

    protected function addWorkerNameCriterion(QueryBuilder $queryBuilder, $workerName = null, $method = null)

    {