3 namespace Drupal\woot\Plugin\QueueWorker;
5 use Drupal\Core\Queue\QueueWorkerBase;
6 use Drupal\Core\Queue\RequeueException;
9 * Queue worker used to test RequeueException.
12 * id = "woot_requeue_exception",
13 * title = @Translation("RequeueException test"),
14 * cron = {"time" = 60}
17 class WootRequeueException extends QueueWorkerBase
23 public function processItem($data)
25 $state = \Drupal::state();
26 if (!$state->get('woot_requeue_exception')) {
27 $state->set('woot_requeue_exception', 1);
28 throw new RequeueException('I am not done yet!');
30 $state->set('woot_requeue_exception', 2);