ConsumeCommand::configure() - Code Metrics - Inspection of "add commands to consume a queue" - Innmind/AMQPBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — develop ( 53c9e6...feab1b )

by Baptiste

created 2017-09-15 06:11 UTC

ConsumeCommand::configure() A

↳ Parent: ConsumeCommand

Complexity

Conditions	1
Paths	1

Size

Total Lines	8
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	8
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	6
nc	1
nop	0

<?php
declare(strict_types = 1);

namespace Innmind\AMQPBundle\Command;

use Innmind\AMQP\Model\Basic\Consume;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\{
    Input\InputInterface,
    Input\InputArgument,
    Output\OutputInterface
};

final class ConsumeCommand extends ContainerAwareCommand
{
    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this
            ->setName('innmind:amqp:consume')
            ->setDescription('Will process messages from the given queue')
            ->addArgument('queue', InputArgument::REQUIRED)
            ->addArgument('number', InputArgument::OPTIONAL, 'The number of messages to process');
    }

    /**
     * {@inheritdoc}
     */
    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);
    }
}


1			<?php
2			declare(strict_types = 1);
3
4			namespace Innmind\AMQPBundle\Command;
5
6			use Innmind\AMQP\Model\Basic\Consume;
7			use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
8			use Symfony\Component\Console\{
9			Input\InputInterface,
10			Input\InputArgument,
11			Output\OutputInterface
12			};
13
14			final class ConsumeCommand extends ContainerAwareCommand
15			{
16			/**
17			* {@inheritdoc}
18			*/
19			protected function configure()
20			{
21			$this
22			->setName('innmind:amqp:consume')
23			->setDescription('Will process messages from the given queue')
24			->addArgument('queue', InputArgument::REQUIRED)
25			->addArgument('number', InputArgument::OPTIONAL, 'The number of messages to process');
26			}
27
28			/**
29			* {@inheritdoc}
30			*/
31			protected function execute(InputInterface $input, OutputInterface $output)
32			{
33			$queue = $input->getArgument('queue');
34			$consume = $this
35			->getContainer()
36			->get('innmind.amqp.consumers')
37			->get($queue);
38
39			$consumer = $this
40			->getContainer()
41			->get('innmind.amqp.client')
42			->channel()
43			->basic()
44			->consume(new Consume($queue));
45
46			if ($input->getArgument('number')) {
47			$consumer->take((int) $input->getArgument('number'));
48			}
49
50			$consumer->foreach($consume);
51			}
52			}
53

Innmind / AMQPBundle

Push — develop ( 53c9e6...feab1b )

ConsumeCommand::configure() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like