JobSchedulerQueue.php in Job Scheduler 8.3

Namespace

Drupal\job_scheduler\Plugin\QueueWorker

File

src/Plugin/QueueWorker/JobSchedulerQueue.php

<?php

namespace Drupal\job_scheduler\Plugin\QueueWorker;

use Drupal\Core\Queue\QueueWorkerBase;
use Drupal\job_scheduler\Entity\JobSchedule;

/**
 * Providing our own worker has the advantage that we can reschedule the job or
 * take care of cleanup. Note that as we run the execute() action, the job won't
 * be queued again this time.
 *
 * @QueueWorker(
 *   id = "job_scheduler_queue",
 *   title = @Translation("Job Scheduler Queue"),
 *   cron = {"time" = 60},
 *   deriver = "Drupal\job_scheduler\Plugin\Derivative\JobSchedulerQueueWorker"
 * )
 */
class JobSchedulerQueue extends QueueWorkerBase {

  /**
   * The name of this scheduler.
   *
   * @var \Drupal\job_scheduler\JobScheduler
   */
  protected $scheduler;

  /**
   * {@inheritdoc}
   */
  public function __construct(array $configuration, $plugin_id, $plugin_definition) {
    parent::__construct($configuration, $plugin_id, $plugin_definition);
    $this->scheduler = \Drupal::service('job_scheduler.manager');
  }

  /**
   * {@inheritdoc}
   */
  public function processItem($id) {
    $job = JobSchedule::load($id);
    $scheduler = $this->scheduler;
    try {
      $scheduler
        ->execute($job);
    } catch (\Exception $e) {
      watchdog_exception('job_scheduler', $e);

      // Drop jobs that have caused exceptions.
      $job
        ->delete();
    }
  }

}

Classes

Name	Description
JobSchedulerQueue	Providing our own worker has the advantage that we can reschedule the job or take care of cleanup. Note that as we run the execute() action, the job won't be queued again this time.