RedisQueueTest.php in Redis 8

Namespace

Drupal\Tests\redis\Kernel

File

tests/src/Kernel/RedisQueueTest.php

<?php

namespace Drupal\Tests\redis\Kernel;

use Drupal\redis\ClientFactory;
use Drupal\KernelTests\Core\Queue\QueueTest as CoreQueueTest;
use Drupal\Tests\redis\Traits\RedisTestInterfaceTrait;

/**
 * Tests the Redis queue functions.
 *
 * @group redis
 */
class RedisQueueTest extends CoreQueueTest {
  use RedisTestInterfaceTrait;

  /**
   * Modules to enable.
   *
   * @var array
   */
  public static $modules = [
    'redis',
  ];

  /**
   * Tests Redis non-blocking queue.
   */
  public function testRedisNonBlockingQueue() {
    self::setUpSettings();
    $client_factory = \Drupal::service('redis.factory');
    $settings = [
      'reserve_timeout' => NULL,
    ];
    $class_name = $client_factory
      ->getClass(ClientFactory::REDIS_IMPL_QUEUE);

    /** @var \Drupal\Core\Queue\QueueInterface $queue1 */
    $queue1 = new $class_name($this
      ->randomMachineName(), $settings, $client_factory
      ->getClient());
    $queue1
      ->createQueue();

    /** @var \Drupal\Core\Queue\QueueInterface $queue2 */
    $queue2 = new $class_name($this
      ->randomMachineName(), $settings, $client_factory
      ->getClient());
    $queue2
      ->createQueue();
    $this
      ->runQueueTest($queue1, $queue2);
    $queue1
      ->deleteQueue();
    $queue2
      ->deleteQueue();
    $class_name = $client_factory
      ->getClass(ClientFactory::REDIS_IMPL_RELIABLE_QUEUE);

    /** @var \Drupal\Core\Queue\QueueInterface $queue1 */
    $queue1 = new $class_name($this
      ->randomMachineName(), $settings, $client_factory
      ->getClient());
    $queue1
      ->createQueue();

    /** @var \Drupal\Core\Queue\QueueInterface $queue2 */
    $queue2 = new $class_name($this
      ->randomMachineName(), $settings, $client_factory
      ->getClient());
    $queue2
      ->createQueue();
    $this
      ->runQueueTest($queue1, $queue2);
  }

  /**
   * Tests Redis blocking queue.
   */
  public function testRedisBlockingQueue() {
    self::setUpSettings();

    // Create two queues.
    $client_factory = \Drupal::service('redis.factory');
    $settings = [
      'reserve_timeout' => 30,
    ];
    $class_name = $client_factory
      ->getClass(ClientFactory::REDIS_IMPL_QUEUE);

    /** @var \Drupal\Core\Queue\QueueInterface $queue1 */
    $queue1 = new $class_name($this
      ->randomMachineName(), $settings, $client_factory
      ->getClient());
    $queue1
      ->createQueue();

    /** @var \Drupal\Core\Queue\QueueInterface $queue2 */
    $queue2 = new $class_name($this
      ->randomMachineName(), $settings, $client_factory
      ->getClient());
    $queue2
      ->createQueue();
    $this
      ->runQueueTest($queue1, $queue2);
  }

  /**
   * Overrides \Drupal\system\Tests\Queue\QueueTestQueueTest::testSystemQueue().
   *
   * We override tests from core class we extend to prevent them from running.
   */
  public function testSystemQueue() {
    $this
      ->markTestSkipped();
  }

  /**
   * Overrides \Drupal\system\Tests\Queue\QueueTestQueueTest::testMemoryQueue().
   *
   * We override tests from core class we extend to prevent them from running.
   */
  public function testMemoryQueue() {
    $this
      ->markTestSkipped();
  }

}

Classes

Name	Description
RedisQueueTest	Tests the Redis queue functions.