aleph1.co.uk Git - yaffs-website/blob - web/core/modules/system/tests/modules/cron_queue_test/src/Plugin/QueueWorker/CronQueueTestRequeueException.php

   1 <?php
   2
   3 namespace Drupal\cron_queue_test\Plugin\QueueWorker;
   4
   5 use Drupal\Core\Queue\QueueWorkerBase;
   6 use Drupal\Core\Queue\RequeueException;
   7
   8 /**
   9  * @QueueWorker(
  10  *   id = "cron_queue_test_requeue_exception",
  11  *   title = @Translation("RequeueException test"),
  12  *   cron = {"time" = 60}
  13  * )
  14  */
  15 class CronQueueTestRequeueException extends QueueWorkerBase {
  16
  17   /**
  18    * {@inheritdoc}
  19    */
  20   public function processItem($data) {
  21     $state = \Drupal::state();
  22     if (!$state->get('cron_queue_test_requeue_exception')) {
  23       $state->set('cron_queue_test_requeue_exception', 1);
  24       throw new RequeueException('I am not done yet!');
  25     }
  26     else {
  27       $state->set('cron_queue_test_requeue_exception', 2);
  28     }
  29   }
  30
  31 }