Innmind\AMQP\Command\Get

Complexity

Total Complexity

3

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

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

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Command;

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

final class Get 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);

        try {
            $this
                ->client
                ->channel()
                ->basic()
                ->get(new Basic\Get($queue))($consume);
        } finally {
            $this->client->close();
        }
    }

    public function __toString(): string
    {
        return <<<USAGE
innmind:amqp:get queue

Will process a single message from the given queue
USAGE;
    }
}