You are here

JobSchedulerQueue.php in Job Scheduler 8.2

Same filename and directory in other branches
  1. 8.3 src/Plugin/QueueWorker/JobSchedulerQueue.php

File

src/Plugin/QueueWorker/JobSchedulerQueue.php
View source
<?php

namespace Drupal\job_scheduler\Plugin\QueueWorker;

use Drupal\Core\Queue\QueueWorkerBase;

/**
 * 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($job) {
    $scheduler = $this->scheduler;
    try {
      $scheduler
        ->execute($job);
    } catch (\Exception $e) {
      watchdog_exception('job_scheduler', $e);

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

}

Classes

Namesort descending 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.