protected function FeedsCommonTrait::runCompleteQueue in Feeds 8.3

Runs all items from one queue.

Parameters

string $queue_name: The name of the queue to run all items from.

1 call to FeedsCommonTrait::runCompleteQueue()

FeedTest::testPushImport in tests/src/Kernel/Entity/FeedTest.php

@covers ::pushImport

File

tests/src/Traits/FeedsCommonTrait.php, line 194

Class

FeedsCommonTrait

Provides methods useful for Kernel and Functional Feeds tests.

Namespace

Drupal\Tests\feeds\Traits

Code

protected function runCompleteQueue($queue_name) {

  // Create queue.
  $queue = \Drupal::service('queue')
    ->get($queue_name);
  $queue
    ->createQueue();
  $queue_worker = \Drupal::service('plugin.manager.queue_worker')
    ->createInstance($queue_name);

  // Process all items of queue.
  while ($item = $queue
    ->claimItem()) {
    $queue_worker
      ->processItem($item->data);
    $queue
      ->deleteItem($item);
  }
}