public function CronQueueTest::testExceptions in Zircon Profile 8

Same name and namespace in other branches

1. 8.0 core/modules/system/src/Tests/System/CronQueueTest.php \Drupal\system\Tests\System\CronQueueTest::testExceptions()

Tests that exceptions thrown by workers are handled properly.

File

core/modules/system/src/Tests/System/CronQueueTest.php, line 29

Contains \Drupal\system\Tests\System\CronQueueTest.

Class

CronQueueTest

Tests the Cron Queue runner.

Namespace

Drupal\system\Tests\System

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(array(
    $this
      ->randomMachineName() => $this
      ->randomMachineName(),
  ));

  // Run cron; the worker for this queue should throw an exception and handle
  // it.
  $this
    ->cronRun();

  // The item should be left in the queue.
  $this
    ->assertEqual($queue
    ->numberOfItems(), 1, 'Failing item still in the queue after throwing an exception.');

  // 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
    ->cronRun();

  // Only one item should have been processed.
  $this
    ->assertEqual($queue
    ->numberOfItems(), 2, '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
    ->assertEqual($item->data, 'crash', 'Failing item remains in the queue.');
  $item = $queue
    ->claimItem();
  $this
    ->assertEqual($item->data, 'ignored', 'Item beyond the failing item remains in the queue.');
}