Consume::__invoke() - Code Metrics - Inspection of "Merge branch 'develop'" - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( fc45f0...dd0edf )

by Baptiste

created 2018-02-25 11:04 UTC

Consume::__invoke() B

↳ Parent: Consume

Complexity

Conditions	4
Paths	12

Size

Total Lines	22
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	14
CRAP Score	4

Importance

Changes

Metric	Value
cc	4
eloc	14
nc	12
nop	3
dl	0
loc	22
ccs	14
cts	14
cp	1
crap	4
rs	8.9197
c	0
b	0
f	0

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Command;

use Innmind\AMQP\{
    Client,
    Consumers,
    Model\Basic,
    Model\Basic\Qos,
};
use Innmind\CLI\{
    Command,
    Command\Arguments,
    Command\Options,
    Environment,
};

final class Consume implements Command
{
    private $client;
    private $consumers;

    public function __construct(Client $client, Consumers $consumers)
    {
        $this->client = $client;
        $this->consumers = $consumers;
    }

    public function __invoke(Environment $env, Arguments $arguments, Options $options): void
    {
        $queue = $arguments->get('queue');
        $consume = $this->consumers->get($queue);
        $basic = $this->client->channel()->basic();

        if ($arguments->contains('prefetch')) {
            $basic->qos(new Qos(0, (int) $arguments->get('prefetch')));
        } else if ($arguments->contains('number')) {
            $basic->qos(new Qos(0, (int) $arguments->get('number')));
        }

        $consumer = $basic->consume(new Basic\Consume($queue));

        if ($arguments->contains('number')) {
            $consumer->take((int) $arguments->get('number'));
        }

        try {
            $consumer->foreach($consume);
        } finally {
            $this->client->close();
        }
    }

    public function __toString(): string
    {
        return <<<USAGE
innmind:amqp:consume queue [number] [prefetch]

Will process messages from the given queue
USAGE;
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\AMQP\Command;
5
6		use Innmind\AMQP\{
7		Client,
8		Consumers,
9		Model\Basic,
10		Model\Basic\Qos,
11		};
12		use Innmind\CLI\{
13		Command,
14		Command\Arguments,
15		Command\Options,
16		Environment,
17		};
18
19		final class Consume implements Command
20		{
21		private $client;
22		private $consumers;
23
24	7	public function __construct(Client $client, Consumers $consumers)
25		{
26	7	$this->client = $client;
27	7	$this->consumers = $consumers;
28	7	}
29
30	4	public function __invoke(Environment $env, Arguments $arguments, Options $options): void
31		{
32	4	$queue = $arguments->get('queue');
33	4	$consume = $this->consumers->get($queue);
34	4	$basic = $this->client->channel()->basic();
35
36	4	if ($arguments->contains('prefetch')) {
37	1	$basic->qos(new Qos(0, (int) $arguments->get('prefetch')));
38	3	} else if ($arguments->contains('number')) {
39	1	$basic->qos(new Qos(0, (int) $arguments->get('number')));
40		}
41
42	4	$consumer = $basic->consume(new Basic\Consume($queue));
43
44	4	if ($arguments->contains('number')) {
45	2	$consumer->take((int) $arguments->get('number'));
46		}
47
48		try {
49	4	$consumer->foreach($consume);
50	3	} finally {
51	4	$this->client->close();
52		}
53	3	}
54
55	1	public function __toString(): string
56		{
57		return <<<USAGE
58	1	innmind:amqp:consume queue [number] [prefetch]
59
60		Will process messages from the given queue
61		USAGE;
62		}
63		}
64

Innmind / AMQP

GitHub Access Token became invalid

Push — master ( fc45f0...dd0edf )

Consume::__invoke() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like