function CronQueueTest::testUncaughtExceptions

Tests that non-queue exceptions thrown by workers are handled properly.

See also

\Drupal\cron_queue_test\Plugin\QueueWorker\CronQueueTestException

File

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

Class

CronQueueTest

Tests the Cron Queue runner.

Namespace

Code

public function testUncaughtExceptions() : void {
    $this->logger
        ->log(RfcLogLevel::ERROR, '%type: @message in %function (line %line of %file).', Argument::that(function ($args) {
        return $args['@message'] === 'That is not supposed to happen.' && $args['exception'] instanceof \Exception;
    }))
        ->shouldBeCalled();
    $this->logger
        ->log(RfcLogLevel::INFO, 'Cron run completed.', Argument::cetera())
        ->shouldBeCalled();
    // Get the queue to test the normal Exception.
    $queue = $this->container
        ->get('queue')
        ->get(CronQueueTestException::PLUGIN_ID);
    // 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
    // \Drupal::time()->getRequestTime() to find queue items whose expire field needs to be
    // reset to 0. This is a Kernel test, so \Drupal::time()->getRequestTime() 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.');
}