yrc\components\Queue

Complexity

Total Complexity

4

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setClients()	0	8	2
A	get()	0	4	1
A	addJob()	0	5	1

<?php

namespace yrc\components;

use Yii;
use yii\base\Object;
use Disque\Connection\Credentials;
use Disque\Client;

/**
 * Disque Manager
 * @class Queue
 */
class Queue extends Object
{
    /**
     * An array of Disque connections
     * @param array $nodes
     */
    private $nodes;

    /**
     * Adds client connections
     * @param array $clients
     * @return true
     */
    public function setClients($clients = [])
    {
        foreach ($clients as $client) {
            $this->nodes[] = new Credentials($client['host'], $client['port'], $client['password']);
        }

        return true;
    }

    /**
     * Retrieves the queue
     * @return Disque\Client
     */
    public function get()
    {
        return new Client($this->nodes);

$this->nodes is of type array<integer,object<Disque\Connection\Credentials>>, but the function expects a array<integer,object<Disque\Disque\Connection\Credentials>>.

    }

    /**
     * Adds a new job to a queue
     * @param array $jobProperties
     * @param string $queueName
     * return
     */
    public function addJob($jobProperties = [], $queueName = 'app')
    {
        $job = new \Disque\Queue\Job($jobProperties);
        return $this->get()->queue($queueName)->push($job);
    }
}