public function UpdateNonExistentTest::onProcess in Feeds 8.3

Acts on processing a single item.

Parameters

\Drupal\feeds\Event\ProcessEvent $event: The process event.

File

tests/src/Functional/UpdateNonExistentTest.php, line 376

Class

UpdateNonExistentTest

Tests the feature of updating items that are no longer available in the feed.

Namespace

Drupal\Tests\feeds\Functional

Code

public function onProcess(ProcessEvent $event) {

  // Claim another queue item.
  $feed_type_id = $event
    ->getFeed()
    ->getType()
    ->id();
  $queue_name = 'feeds_feed_refresh:' . $feed_type_id;
  $queue = $this->container
    ->get('queue')
    ->get($queue_name);
  $queue_worker = $this->container
    ->get('plugin.manager.queue_worker')
    ->createInstance($queue_name);
  $item = $queue
    ->claimItem();
  if ($item) {
    $queue_worker
      ->processItem($item->data);
    $queue
      ->deleteItem($item);
  }
}