protected function QueueService::initializeQueue in Purge 8.3

Initialize the transaction buffer and queue backend.

9 calls to QueueService::initializeQueue()

QueueService::claim in src/Plugin/Purge/Queue/QueueService.php

Claim invalidation objects from the queue.

QueueService::commitAdding in src/Plugin/Purge/Queue/QueueService.php

Commit all adding invalidations in the buffer to the queue.

QueueService::commitDeleting in src/Plugin/Purge/Queue/QueueService.php

Commit all deleting invalidations in the buffer to the queue.

QueueService::commitReleasing in src/Plugin/Purge/Queue/QueueService.php

Commit all releasing invalidations in the buffer to the queue.

QueueService::emptyQueue in src/Plugin/Purge/Queue/QueueService.php

Empty the entire queue.

... See full list

File

src/Plugin/Purge/Queue/QueueService.php, line 408

Class

QueueService

Provides the service that lets invalidations interact with a queue backend.

Namespace

Drupal\purge\Plugin\Purge\Queue

Code

protected function initializeQueue() {
  if (!is_null($this->queue)) {
    return;
  }

  // Lookup the plugin ID and instantiate the queue.
  $plugin_id = current($this
    ->getPluginsEnabled());
  $this->logger
    ->debug("backend: @plugin_id.", [
    '@plugin_id' => $plugin_id,
  ]);
  $this->queue = $this->pluginManager
    ->createInstance($plugin_id);
}