Source of file QueueRunner.php
Size: 0,747 Bytes - Last Modified: 2021-12-23T10:33:37+00:00
/var/www/docs.ssmods.com/process/src/src/Tasks/Engines/QueueRunner.php
1234567891011121314151617181920212223242526272829303132 | <?php namespace Symbiote\QueuedJobs\Tasks\Engines; use Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor; use Symbiote\QueuedJobs\Services\QueuedJobService; /** * Runs all jobs in a queue loop in one process */ class QueueRunner extends BaseRunner implements TaskRunnerEngine { /** * @param string $queue */ public function runQueue($queue) { if (QueuedJobService::singleton()->isMaintenanceLockActive()) { return; } $service = $this->getService(); $nextJob = $service->getNextPendingJob($queue); $this->logDescriptorStatus($nextJob, $queue); if ($nextJob instanceof QueuedJobDescriptor) { $service->processJobQueue($queue); } } } |