yrc\components\RPQComponent

Complexity

Total Complexity

3

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getQueue()	0	3	1
A	getClient()	0	3	1
A	init()	0	6	1

<?php


namespace yrc\components;


use Redis;

use RPQ\Client;

use yii\base\BaseObject;

use Yii;


final class RPQComponent extends BaseObject

{

    /**

     * @var array $redis

     */

    public $redis = [

        'host' => '127.0.0.1',

        'port' => 6379,

        'database' => 0,

        'namespace' => 'rpq'

    ];


    /**

     * @var array $queues

     */

    public $queues;


    /**

     * @var RPQ\Client $client

The type yrc\components\RPQ\Client was not found. Did you mean RPQ\Client? If so, make sure to prefix the type with \.

     */

    private $client;


    /**

     * Returns the RPQ Client

     * @return RPQ\Client

     */

    public function getClient()

    {

        return $this->client;

    }


    /**

     * Returns the queue object

     * @param string $name

     * @return array

     */

    public function getQueue($name = 'default')

    {

        return $this->getClient()->getQueue($name);

    }


    public function init()

    {

        parent::init();

        $redis = new Redis;

        $redis->connect($this->redis['host'], $this->redis['port']);

        $this->client = new Client($redis, $this->redis['namespace']);

It seems like new RPQ\Client($redis, $this->redis['namespace']) of type RPQ\Client is incompatible with the declared type yrc\components\RPQ\Client of property $client.

    }

}