Same name and namespace in other branches

1. 10 core/lib/Drupal/Core/Cron.php \Drupal\Core\Cron::processQueue()

Processes a cron queue.

Parameters

\Drupal\Core\Queue\QueueInterface $queue: The queue.

\Drupal\Core\Queue\QueueWorkerInterface $worker: The queue worker.

Throws

\Drupal\Core\Queue\SuspendQueueException If the queue was suspended.

1 call to Cron::processQueue()

Cron::processQueues in core/lib/Drupal/Core/Cron.php

Processes cron queues.

File

core/lib/Drupal/Core/Cron.php, line 201

Class

Cron

The Drupal core Cron service.

Namespace

Drupal\Core

Code

protected function processQueue(QueueInterface $queue, QueueWorkerInterface $worker) {
    $lease_time = $worker->getPluginDefinition()['cron']['time'];
    $end = $this->time
        ->getCurrentTime() + $lease_time;
    while ($this->time
        ->getCurrentTime() < $end && ($item = $queue->claimItem($lease_time))) {
        try {
            $worker->processItem($item->data);
            $queue->deleteItem($item);
        } catch (DelayedRequeueException $e) {
            // The worker requested the task not be immediately re-queued.
            // - If the queue doesn't support ::delayItem(), we should leave the
            // item's current expiry time alone.
            // - If the queue does support ::delayItem(), we should allow the
            // queue to update the item's expiry using the requested delay.
            if ($queue instanceof DelayableQueueInterface) {
                // This queue can handle a custom delay; use the duration provided
                // by the exception.
                $queue->delayItem($item, $e->getDelay());
            }
        } catch (RequeueException) {
            // The worker requested the task be immediately requeued.
            $queue->releaseItem($item);
        } catch (SuspendQueueException $e) {
            // If the worker indicates the whole queue should be skipped, release
            // the item and go to the next queue.
            $queue->releaseItem($item);
            $this->logger
                ->debug('A worker for @queue queue suspended further processing of the queue.', [
                '@queue' => $worker->getPluginId(),
            ]);
            // Skip to the next queue.
            throw $e;
        } catch (\Exception $e) {
            // In case of any other kind of exception, log it and leave the item
            // in the queue to be processed again later.
            Error::logException($this->logger, $e);
        }
    }
}

---