Version 1

[yaffs-website] / web / core / modules / system / tests / modules / cron_queue_test / src / Plugin / QueueWorker / CronQueueTestException.php

diff --git a/web/core/modules/system/tests/modules/cron_queue_test/src/Plugin/QueueWorker/CronQueueTestException.php b/web/core/modules/system/tests/modules/cron_queue_test/src/Plugin/QueueWorker/CronQueueTestException.php
new file mode 100644 (file)
index 0000000..b6ef791
--- /dev/null
+++ b/web/core/modules/system/tests/modules/cron_queue_test/src/Plugin/QueueWorker/CronQueueTestException.php
@@ -0,0 +1,30 @@
+<?php
+
+namespace Drupal\cron_queue_test\Plugin\QueueWorker;
+
+use Drupal\Core\Queue\QueueWorkerBase;
+
+/**
+ * @QueueWorker(
+ *   id = "cron_queue_test_exception",
+ *   title = @Translation("Exception test"),
+ *   cron = {"time" = 1}
+ * )
+ */
+class CronQueueTestException extends QueueWorkerBase {
+
+  /**
+   * {@inheritdoc}
+   */
+  public function processItem($data) {
+    $state = \Drupal::state();
+    if (!$state->get('cron_queue_test_exception')) {
+      $state->set('cron_queue_test_exception', 1);
+      throw new \Exception('That is not supposed to happen.');
+    }
+    else {
+      $state->set('cron_queue_test_exception', 2);
+    }
+  }
+
+}