BaseConsumerCommand::handle() - Code Metrics - Inspection of "Merge pull request #12 from needle-project/develop" - needle-project/laravel-rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (f63365)

by Adrian Florin

created 2018-08-06 14:15 UTC

BaseConsumerCommand::handle() A

↳ Parent: BaseConsumerCommand

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	10
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	16
ccs	10
cts	10
cp	1
rs	9.7333
c	0
b	0
f	0
cc	2
nc	2
nop	0
crap	2

<?php
namespace NeedleProject\LaravelRabbitMq\Command;

use Illuminate\Console\Command;
use NeedleProject\LaravelRabbitMq\ConsumerInterface;

/**
 * Class BaseConsumerCommand
 *
 * @package NeedleProject\LaravelRabbitMq\Command
 */
class BaseConsumerCommand extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'rabbitmq:consume {consumer} {--time=60} {--messages=100} {--memory=64}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Start consuming messages';

    /**
     * @param string $consumerAliasName
     * @return ConsumerInterface
     */
    protected function getConsumer(string $consumerAliasName): ConsumerInterface
    {
        return app()->makeWith(ConsumerInterface::class, [$consumerAliasName]);
    }

    /**
     * Execute the console command.
     * @return int
     */
    public function handle()
    {
        $messageCount = $this->input->getOption('messages');
        $waitTime = $this->input->getOption('time');
        $memoryLimit = $this->input->getOption('memory');

        /** @var ConsumerInterface $consumer */
        $consumer = $this->getConsumer($this->input->getArgument('consumer'));
        try {
            return $consumer->startConsuming($messageCount, $waitTime, $memoryLimit);
        } catch (\Throwable $e) {
            $consumer->stopConsuming();
            $this->output->error($e->getMessage());
            return -1;
        }
    }
}


1		<?php
2		namespace NeedleProject\LaravelRabbitMq\Command;
3
4		use Illuminate\Console\Command;
5		use NeedleProject\LaravelRabbitMq\ConsumerInterface;
6
7		/**
8		* Class BaseConsumerCommand
9		*
10		* @package NeedleProject\LaravelRabbitMq\Command
11		*/
12		class BaseConsumerCommand extends Command
13		{
14		/**
15		* The name and signature of the console command.
16		*
17		* @var string
18		*/
19		protected $signature = 'rabbitmq:consume {consumer} {--time=60} {--messages=100} {--memory=64}';
20
21		/**
22		* The console command description.
23		*
24		* @var string
25		*/
26		protected $description = 'Start consuming messages';
27
28		/**
29		* @param string $consumerAliasName
30		* @return ConsumerInterface
31		*/
32		protected function getConsumer(string $consumerAliasName): ConsumerInterface
33		{
34		return app()->makeWith(ConsumerInterface::class, [$consumerAliasName]);
35		}
36
37		/**
38		* Execute the console command.
39		* @return int
40		*/
41	2	public function handle()
42		{
43	2	$messageCount = $this->input->getOption('messages');
44	2	$waitTime = $this->input->getOption('time');
45	2	$memoryLimit = $this->input->getOption('memory');
46
47		/** @var ConsumerInterface $consumer */
48	2	$consumer = $this->getConsumer($this->input->getArgument('consumer'));
49		try {
50	2	return $consumer->startConsuming($messageCount, $waitTime, $memoryLimit);
51	1	} catch (\Throwable $e) {
52	1	$consumer->stopConsuming();
53	1	$this->output->error($e->getMessage());
54	1	return -1;
55		}
56		}
57		}
58

needle-project / laravel-rabbitmq

Branch — master (f63365)

BaseConsumerCommand::handle() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like