Innmind\AMQPBundle\Command\ConsumeCommand::execute()

Complexity

Conditions	4
Paths	4

Size

Total Lines	28
Code Lines	19

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	18
CRAP Score	4

Importance

Changes	1
Bugs	0	Features	1

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $queue = $input->getArgument('queue');
        $number = $input->getArgument('number');
        $prefetch = $input->getArgument('prefetch');
        $consume = $this
            ->getContainer()
            ->get('innmind.amqp.consumers')
            ->get($queue);

        $basic = $this
            ->getContainer()
            ->get('innmind.amqp.client')
            ->channel()
            ->basic();

        if (!is_null($number) || !is_null($prefetch)) {
            $basic->qos(new Qos(0, (int) ($prefetch ?? $number)));
        }

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

        if (!is_null($number)) {
            $consumer->take((int) $number);
        }

        $consumer->foreach($consume);
    }
}