function CronQueueTest::testExceptions

Tests that exceptions thrown by workers are handled properly.

File

core/modules/system/tests/src/Kernel/System/CronQueueTest.php, line 157

Class

CronQueueTest

Tests the Cron Queue runner.

Namespace

Code

public function testExceptions() {
  // Get the queue to test the normal Exception.
  $queue = $this->container
    ->get('queue')
    ->get('cron_queue_test_exception');
  // Enqueue an item for processing.
  $queue->createItem([
    $this->randomMachineName() => $this->randomMachineName(),
  ]);
  // Run cron; the worker for this queue should throw an exception and handle
  // it.
  $this->cron
    ->run();
  $this->assertEquals(1, \Drupal::state()->get('cron_queue_test_exception'));
  // The item should be left in the queue.
  $this->assertEquals(1, $queue->numberOfItems(), 'Failing item still in the queue after throwing an exception.');
  // Expire the queue item manually. system_cron() relies in REQUEST_TIME to
  // find queue items whose expire field needs to be reset to 0. This is a
  // Kernel test, so REQUEST_TIME won't change when cron runs.
  // @see system_cron()
  // @see \Drupal\Core\Cron::processQueues()
  $this->connection
    ->update('queue')
    ->condition('name', 'cron_queue_test_exception')
    ->fields([
    'expire' => \Drupal::time()->getRequestTime() - 1,
  ])
    ->execute();
  $this->cron
    ->run();
  $this->assertEquals(2, \Drupal::state()->get('cron_queue_test_exception'));
  $this->assertEquals(0, $queue->numberOfItems(), 'Item was processed and removed from the queue.');
  // Get the queue to test the specific SuspendQueueException.
  $queue = $this->container
    ->get('queue')
    ->get('cron_queue_test_broken_queue');
  // Enqueue several item for processing.
  $queue->createItem('process');
  $queue->createItem('crash');
  $queue->createItem('ignored');
  // Run cron; the worker for this queue should process as far as the crashing
  // item.
  $this->cron
    ->run();
  // Only one item should have been processed.
  $this->assertEquals(2, $queue->numberOfItems(), 'Failing queue stopped processing at the failing item.');
  // Check the items remaining in the queue. The item that throws the
  // exception gets released by cron, so we can claim it again to check it.
  $item = $queue->claimItem();
  $this->assertEquals('crash', $item->data, 'Failing item remains in the queue.');
  $item = $queue->claimItem();
  $this->assertEquals('ignored', $item->data, 'Item beyond the failing item remains in the queue.');
  // Test the requeueing functionality.
  $queue = $this->container
    ->get('queue')
    ->get('cron_queue_test_requeue_exception');
  $queue->createItem([]);
  $this->cron
    ->run();
  $this->assertEquals(2, \Drupal::state()->get('cron_queue_test_requeue_exception'));
  $this->assertEquals(0, $queue->numberOfItems());
}