Beanstalkd/JobManager.php 1 location
|
@@ 66-79 (lines=14) @@
|
| 63 |
|
return $job; |
| 64 |
|
} |
| 65 |
|
|
| 66 |
|
protected function resetJob(RetryableJob $job) |
| 67 |
|
{ |
| 68 |
|
if (!$job instanceof Job) { |
| 69 |
|
throw new \InvalidArgumentException('$job must be instance of '.Job::class); |
| 70 |
|
} |
| 71 |
|
$job->setStatus(BaseJob::STATUS_NEW); |
| 72 |
|
$job->setMessage(null); |
| 73 |
|
$job->setStartedAt(null); |
| 74 |
|
$job->setRetries($job->getRetries() + 1); |
| 75 |
|
$job->setUpdatedAt(Util::getMicrotimeDateTime()); |
| 76 |
|
$this->putJob($job); |
| 77 |
|
|
| 78 |
|
return true; |
| 79 |
|
} |
| 80 |
|
|
| 81 |
|
public function getBeanJob($jobId, $data) |
| 82 |
|
{ |
Doctrine/DoctrineJobManager.php 1 location
|
@@ 380-394 (lines=15) @@
|
| 377 |
|
return 1; |
| 378 |
|
} |
| 379 |
|
|
| 380 |
|
protected function resetJob(RetryableJob $job) |
| 381 |
|
{ |
| 382 |
|
if (!$job instanceof StallableJob) { |
| 383 |
|
throw new \InvalidArgumentException('$job should be instance of '.StallableJob::class); |
| 384 |
|
} |
| 385 |
|
$job->setStatus(BaseJob::STATUS_NEW); |
| 386 |
|
$job->setMessage(null); |
| 387 |
|
$job->setFinishedAt(null); |
| 388 |
|
$job->setStartedAt(null); |
| 389 |
|
$job->setElapsed(null); |
| 390 |
|
$job->setRetries($job->getRetries() + 1); |
| 391 |
|
$this->persist($job); |
| 392 |
|
|
| 393 |
|
return true; |
| 394 |
|
} |
| 395 |
|
|
| 396 |
|
abstract protected function persist($object, $action = 'persist'); |
| 397 |
|
|
RabbitMQ/JobManager.php 1 location
|
@@ 255-269 (lines=15) @@
|
| 252 |
|
return null; |
| 253 |
|
} |
| 254 |
|
|
| 255 |
|
protected function resetJob(RetryableJob $job) |
| 256 |
|
{ |
| 257 |
|
if (!$job instanceof Job) { |
| 258 |
|
throw new \InvalidArgumentException('$job must be instance of '.Job::class); |
| 259 |
|
} |
| 260 |
|
$job->setStatus(BaseJob::STATUS_NEW); |
| 261 |
|
$job->setMessage(null); |
| 262 |
|
$job->setStartedAt(null); |
| 263 |
|
$job->setDeliveryTag(null); |
| 264 |
|
$job->setRetries($job->getRetries() + 1); |
| 265 |
|
$job->setUpdatedAt(Util::getMicrotimeDateTime()); |
| 266 |
|
$this->publishJob($job); |
| 267 |
|
|
| 268 |
|
return true; |
| 269 |
|
} |
| 270 |
|
|
| 271 |
|
// Save History get called upon completion of the job |
| 272 |
|
protected function retryableSaveHistory(RetryableJob $job, $retry) |
Redis/BaseJobManager.php 1 location
|
@@ 78-91 (lines=14) @@
|
| 75 |
|
|
| 76 |
|
abstract protected function saveJob(Job $job); |
| 77 |
|
|
| 78 |
|
public function resetJob(RetryableJob $job) |
| 79 |
|
{ |
| 80 |
|
if (!$job instanceof Job) { |
| 81 |
|
throw new \InvalidArgumentException('$job must be instance of '.Job::class); |
| 82 |
|
} |
| 83 |
|
$job->setStatus(BaseJob::STATUS_NEW); |
| 84 |
|
$job->setMessage(null); |
| 85 |
|
$job->setStartedAt(null); |
| 86 |
|
$job->setRetries($job->getRetries() + 1); |
| 87 |
|
$job->setUpdatedAt(Util::getMicrotimeDateTime()); |
| 88 |
|
$this->saveJob($job); |
| 89 |
|
|
| 90 |
|
return true; |
| 91 |
|
} |
| 92 |
|
|
| 93 |
|
public function deleteJob(\Dtc\QueueBundle\Model\Job $job) |
| 94 |
|
{ |
mmucklo /
DtcQueueBundle
