Innmind\AMQP\Command\Consume

Complexity

Total Complexity

6

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__toString()	0	3	1
B	__invoke()	0	22	4

<?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;
    }
}