QueueRedisFactory.php in Redis 8

Namespace

Drupal\redis\Queue

File

src/Queue/QueueRedisFactory.php

<?php

namespace Drupal\redis\Queue;

use Drupal\Core\Site\Settings;
use Drupal\redis\ClientFactory;

/**
 * Defines the queue factory for the Redis backend.
 */
class QueueRedisFactory {

  /**
   * Queue implementation class namespace prefix.
   */
  const CLASS_NAMESPACE = ClientFactory::REDIS_IMPL_QUEUE;

  /**
   * @var \Drupal\redis\ClientFactory
   */
  protected $clientFactory;

  /**
   * The settings array.
   *
   * @var \Drupal\Core\Site\Settings
   */
  protected $settings;

  /**
   * Constructs this factory object.
   *
   * @param \Drupal\Core\Database\Connection $connection
   *   The Connection object containing the key-value tables.
   */
  public function __construct(ClientFactory $client_factory, Settings $settings) {
    $this->clientFactory = $client_factory;
    $this->settings = $settings;
  }

  /**
   * Constructs a new queue object for a given name.
   *
   * @param string $name
   *   The name of the collection holding key and value pairs.
   *
   * @return \Drupal\Core\Queue\DatabaseQueue
   *   A key/value store implementation for the given $collection.
   */
  public function get($name) {
    $settings = $this->settings
      ->get('redis_queue_' . $name, [
      'reserve_timeout' => NULL,
    ]);
    $class_name = $this->clientFactory
      ->getClass(static::CLASS_NAMESPACE);
    return new $class_name($name, $settings, $this->clientFactory
      ->getClient());
  }

}

Classes

Name	Description
QueueRedisFactory	Defines the queue factory for the Redis backend.