mmucklo / DtcQueueBundle

        );

    }

    public function getWaitingJobCount($workerName = null, $method = null)

    {

        /** @var EntityManager $objectManager */

        $objectManager = $this->getObjectManager();

        $queryBuilder = $objectManager->createQueryBuilder();

        $queryBuilder = $queryBuilder->select('count(j)')->from($this->getJobClass(), 'j');

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

        $this->addStandardPredicate($queryBuilder);

        $query = $queryBuilder->getQuery();

        return $query->getSingleScalarResult();

    }

    /**

     * Get Jobs statuses.

        return $this->removeOlderThan($this->getJobArchiveClass(), 'updatedAt', $olderThan);

    }

    public function getWaitingJobCount($workerName = null, $method = null)

    {

        /** @var DocumentManager $objectManager */

        $objectManager = $this->getObjectManager();

        $builder = $objectManager->createQueryBuilder($this->getJobClass());

        $builder

            ->find();

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

        $this->addStandardPredicates($builder);

        $query = $builder->getQuery();

        return $this->runQuery($query, 'count', [true], 0);

    }

    /**