Innmind\AMQP\Command\Consume::__invoke()

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

0

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

It seems like $queue can also be of type Innmind\Immutable\StreamInterface; however, parameter $queue of Innmind\AMQP\Consumers::get() does only seem to accept string, maybe add an additional type check?

        $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));

It seems like $queue can also be of type Innmind\Immutable\StreamInterface; however, parameter $queue of Innmind\AMQP\Model\Basic\Consume::__construct() does only seem to accept string, maybe add an additional type check?

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

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