Consumer::consume() - Code Metrics - equip/redis-queue - Measure and Improve Code Quality continuously with Scrutinizer

Consumer::consume() A
last analyzed 2016-02-27 15:22 UTC

↳ Parent: Consumer

Complexity

Conditions	2
Paths	2

Size

Total Lines	14
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	14
ccs	9
cts	9
cp	1
rs	9.4285
cc	2
eloc	9
nc	2
nop	1
crap	2

<?php

namespace Equip\RedisQueue;

use Predis\Client;
use Relay\ResolverInterface;

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

    /**
     * @var ResolverInterface
     */
    private $resolver;

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

    /**
     * @param string $queue
     */
    public function consume($queue)
    {
        $value = $this->client->lpop($queue);
        if ($value === null) {
            return;
        }

        $decoded = json_decode($value, true);
        $command = call_user_func($this->resolver, $decoded['command']);

        $command
            ->withOptions($decoded['options'])
            ->execute();
    }
}


1		<?php
2
3		namespace Equip\RedisQueue;
4
5		use Predis\Client;
6		use Relay\ResolverInterface;
7
8		class Consumer
9		{
10		/**
11		* @var Client
12		*/
13		private $client;
14
15		/**
16		* @var ResolverInterface
17		*/
18		private $resolver;
19
20		/**
21		* @param Client $client
22		* @param ResolverInterface $resolver
23		*/
24	2	public function __construct(Client $client, ResolverInterface $resolver)
25		{
26	2	$this->client = $client;
27	2	$this->resolver = $resolver;
28	2	}
29
30		/**
31		* @param string $queue
32		*/
33	2	public function consume($queue)
34		{
35	2	$value = $this->client->lpop($queue);
36	2	if ($value === null) {
37	1	return;
38		}
39
40	1	$decoded = json_decode($value, true);
41	1	$command = call_user_func($this->resolver, $decoded['command']);
42
43		$command
44	1	->withOptions($decoded['options'])
45	1	->execute();
46	1	}
47		}
48

equip / redis-queue

Consumer::consume() A last analyzed 2016-02-27 15:22 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Consumer::consume() A
last analyzed 2016-02-27 15:22 UTC