LeoCarmo\RedisQueue\RedisClient

Complexity

Total Complexity

5

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setQueueClient()	0	3	1
A	setDefaultQueueClient()	0	3	1
A	client()	0	11	3

<?php

namespace LeoCarmo\RedisQueue;

use LeoCarmo\RedisQueue\Exceptions\QueueWithoutConnectionException;

trait RedisClient
{

    /**
     * @var \Redis
     */
    protected static $redis;

    /**
     * @param string $queue
     * @param \Redis $redis
     */
    public static function setQueueClient(string $queue, \Redis $redis)
    {
        self::$redis[$queue] = $redis;
    }

    /**
     * @param \Redis $redis
     */
    public static function setDefaultQueueClient(\Redis $redis)
    {
        self::$redis['default'] = $redis;
    }

    /**
     * @param string $queue
     * @return \Redis
     *
     * @throws QueueWithoutConnectionException
     */
    protected static function client(string $queue)
    {
        if (self::$redis[$queue]) {
            return self::$redis[$queue];
        }

        if (self::$redis['default']) {
            return self::$redis['default'];
        }

        throw new QueueWithoutConnectionException("Queue {$queue} without redis connection.");
    }
}