Equip\RedisQueue\Publisher

Complexity

Total Complexity

3

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	publish()	0	9	2

<?php

namespace Equip\RedisQueue;

use Equip\Command\CommandInterface;
use Predis\Client;

class Publisher
{
    /**
     * @var Client
     */
    private $client;

    /** 
     * @param Client $client
     */
    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    /**
     * @param string $queue Name of the queue to receive the job
     * @param string $command FQCN for Command class to be executed by the job
     * @param array $options Options for the Command class instance
     */
    public function publish($queue, $command, array $options = [])
    {
        if (!is_subclass_of($command, CommandInterface::class)) {
            throw new \RuntimeException('Class does not implement CommandInterface: ' . $command);
        }

        $job = json_encode(['command' => $command, 'options' => $options]);
        $this->client->rpush($queue, $job);
    }
}