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 |
|
|
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 |
|
{ |
RabbitMQ/JobManager.php 1 location
|
@@ 240-254 (lines=15) @@
|
| 237 |
|
return null; |
| 238 |
|
} |
| 239 |
|
|
| 240 |
|
protected function resetJob(RetryableJob $job) |
| 241 |
|
{ |
| 242 |
|
if (!$job instanceof Job) { |
| 243 |
|
throw new \InvalidArgumentException('$job must be instance of '.Job::class); |
| 244 |
|
} |
| 245 |
|
$job->setStatus(BaseJob::STATUS_NEW); |
| 246 |
|
$job->setMessage(null); |
| 247 |
|
$job->setStartedAt(null); |
| 248 |
|
$job->setDeliveryTag(null); |
| 249 |
|
$job->setRetries($job->getRetries() + 1); |
| 250 |
|
$job->setUpdatedAt(Util::getMicrotimeDateTime()); |
| 251 |
|
$this->publishJob($job); |
| 252 |
|
|
| 253 |
|
return true; |
| 254 |
|
} |
| 255 |
|
|
| 256 |
|
// Save History get called upon completion of the job |
| 257 |
|
protected function retryableSaveHistory(RetryableJob $job, $retry) |
mmucklo /
DtcQueueBundle
