mmucklo / DtcQueueBundle

        return $job;

    }

    protected function resetJob(RetryableJob $job)

    {

        if (!$job instanceof Job) {

            throw new \InvalidArgumentException('$job must be instance of '.Job::class);

        }

        $job->setStatus(BaseJob::STATUS_NEW);

        $job->setMessage(null);

        $job->setStartedAt(null);

        $job->setRetries($job->getRetries() + 1);

        $job->setUpdatedAt(Util::getMicrotimeDateTime());

        $this->putJob($job);

        return true;

    }

    public function getBeanJob($jobId, $data)

    {

        return null;

    }

    protected function resetJob(RetryableJob $job)

    {

        if (!$job instanceof Job) {

            throw new \InvalidArgumentException('$job must be instance of '.Job::class);

        }

        $job->setStatus(BaseJob::STATUS_NEW);

        $job->setMessage(null);

        $job->setStartedAt(null);

        $job->setRetries($job->getRetries() + 1);

        $job->setUpdatedAt(Util::getMicrotimeDateTime());

        $this->publishJob($job);

        return true;

    }

    // Save History get called upon completion of the job

    protected function retryableSaveHistory(RetryableJob $job, $retry)

        return $count;

    }

    public function resetJob(RetryableJob $job)

    {

        if (!$job instanceof Job) {

            throw new \InvalidArgumentException('$job must be instance of '.Job::class);

        }

        $job->setStatus(BaseJob::STATUS_NEW);

        $job->setMessage(null);

        $job->setStartedAt(null);

        $job->setRetries($job->getRetries() + 1);

        $job->setUpdatedAt(Util::getMicrotimeDateTime());

        $this->saveJob($job);

        return true;

    }

    private function collateStatusResults(array &$results, $cacheKey)

    {