public function JobScheduler::dispatch in Job Scheduler 8.2
Same name and namespace in other branches
- 8.3 src/JobScheduler.php \Drupal\job_scheduler\JobScheduler::dispatch()
Dispatches a job.
Executes a worker callback or if schedule declares a queue name, queues a job for execution.
Parameters
array $job: A $job array as passed into set() or read from job_schedule table.
Throws
\Exception Exceptions thrown by code called by this method are passed on.
Overrides JobSchedulerInterface::dispatch
1 call to JobScheduler::dispatch()
- JobScheduler::perform in src/
JobScheduler.php - Perform periodic jobs.
File
- src/
JobScheduler.php, line 107
Class
- JobScheduler
- Manage scheduled jobs.
Namespace
Drupal\job_schedulerCode
public function dispatch(array $job) {
$info = $this
->info($job['name']);
if (!$job['periodic']) {
$this
->remove($job);
}
if (!empty($info['queue name'])) {
$queue_name = 'job_scheduler_queue:' . $info['queue name'];
if (\Drupal::queue($queue_name)
->createItem($job)) {
$this
->reserve($job);
}
}
else {
$this
->execute($job);
}
}