function CronQueueTest::testSuspendQueueException

Tests suspend queue exception is handled properly.

@covers \Drupal\Core\Queue\SuspendQueueException

See also

\Drupal\cron_queue_test\Plugin\QueueWorker\CronQueueTestSuspendQueue

File

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

Class

CronQueueTest

Tests the Cron Queue runner.

Namespace

Code

public function testSuspendQueueException() : void {
    $this->logger
        ->log(RfcLogLevel::DEBUG, 'A worker for @queue queue suspended further processing of the queue.', Argument::that(function ($args) {
        return $args['@queue'] === CronQueueTestSuspendQueue::PLUGIN_ID;
    }))
        ->shouldBeCalled();
    $this->logger
        ->log(RfcLogLevel::INFO, 'Cron run completed.', Argument::cetera())
        ->shouldBeCalled();
    // Get the queue to test the specific SuspendQueueException.
    $queue = \Drupal::queue(CronQueueTestSuspendQueue::PLUGIN_ID);
    // Enqueue several item for processing.
    $queue->createItem('process');
    $queue->createItem('suspend');
    $queue->createItem('ignored');
    // Run cron; the worker for this queue should process as far as the
    // suspending item.
    $this->cron
        ->run();
    // Only one item should have been processed.
    $this->assertEquals(2, $queue->numberOfItems(), 'Suspended queue stopped processing at the suspending 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('suspend', $item->data, 'Suspending item remains in the queue.');
    $item = $queue->claimItem();
    $this->assertEquals('ignored', $item->data, 'Item beyond the suspending item remains in the queue.');
}