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

Complexity

Conditions	2
Paths	2

Size

Total Lines	21
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

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

        $consumer = $this
            ->getContainer()
            ->get('innmind.amqp.client')
            ->channel()
            ->basic()
            ->consume(new Consume($queue));

        if ($input->getArgument('number')) {
            $consumer->take((int) $input->getArgument('number'));
        }

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