for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Symbiote\QueuedJobs\Tasks\Engines;
use Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor;
/**
* Runs all jobs in a queue loop in one process
*/
class QueueRunner extends BaseRunner implements TaskRunnerEngine
{
* @param string $queue
public function runQueue($queue)
$service = $this->getService();
$nextJob = $service->getNextPendingJob($queue);
$this->logDescriptorStatus($nextJob, $queue);
if ($nextJob instanceof QueuedJobDescriptor) {
$service->processJobQueue($queue);
}