MessageProcessorAware::onConsume() - Code Metrics - Inspection of "feat: add gzip compression" - puzzle-org/amqp - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — master (#29)

by Nicolas

created 2017-04-02 21:12 UTC

MessageProcessorAware::onConsume() A

↳ Parent: MessageProcessorAware

Complexity

Conditions	3
Paths	3

Size

Total Lines	12
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes

Metric	Value
dl	0
loc	12
c	0
b	0
f	0
ccs	0
cts	0
cp	0
rs	9.4285
cc	3
eloc	5
nc	3
nop	1
crap	12

<?php

namespace Puzzle\AMQP\Clients\Processors;

use Puzzle\AMQP\Messages\Processor;
use Puzzle\AMQP\WritableMessage;
use Puzzle\AMQP\Messages\OnPublishProcessor;
use Puzzle\AMQP\ReadableMessage;
use Puzzle\AMQP\Messages\OnConsumeProcessor;

trait MessageProcessorAware
{
    private
        $messageProcessors = [];
    
    public function setMessageProcessors(array $processors)
    {
        $this->messageProcessors = [];

        foreach($processors as $processor)
        {
            if($processor instanceof Processor)
            {
                $this->appendMessageProcessor($processor);
            }
        }

        return $this;
    }

    public function appendMessageProcessor(Processor $processor)
    {
        $this->messageProcessors[] = $processor;
        
        return $this;
    }
    
    private function onPublish(WritableMessage $message)
    {
        foreach($this->messageProcessors as $messageProcessor)
        {
            if($messageProcessor instanceof OnPublishProcessor)
            {
                $messageProcessor->onPublish($message);
            }
        }
    }

    private function onConsume(ReadableMessage $message)
    {
        foreach(array_reverse($this->messageProcessors) as $messageProcessor)
        {
            if($messageProcessor instanceof OnConsumeProcessor)
            {
                $message = $messageProcessor->onConsume($message);
            }
        }

        return $message;
    }
}


1		<?php
2
3		namespace Puzzle\AMQP\Clients\Processors;
4
5		use Puzzle\AMQP\Messages\Processor;
6		use Puzzle\AMQP\WritableMessage;
7		use Puzzle\AMQP\Messages\OnPublishProcessor;
8		use Puzzle\AMQP\ReadableMessage;
9		use Puzzle\AMQP\Messages\OnConsumeProcessor;
10
11		trait MessageProcessorAware
12		{
13	4	private
14		$messageProcessors = [];
15	4
16		public function setMessageProcessors(array $processors)
17	4	{
18		$this->messageProcessors = [];
19
20	13	foreach($processors as $processor)
21		{
22	13	if($processor instanceof Processor)
23		{
24	4	$this->appendMessageProcessor($processor);
25	13	}
26	13	}
27
28		return $this;
29		}
30
31		public function appendMessageProcessor(Processor $processor)
32		{
33		$this->messageProcessors[] = $processor;
34
35		return $this;
36		}
37
38		private function onPublish(WritableMessage $message)
39		{
40		foreach($this->messageProcessors as $messageProcessor)
41		{
42		if($messageProcessor instanceof OnPublishProcessor)
43		{
44		$messageProcessor->onPublish($message);
45		}
46		}
47		}
48
49		private function onConsume(ReadableMessage $message)
50		{
51		foreach(array_reverse($this->messageProcessors) as $messageProcessor)
52		{
53		if($messageProcessor instanceof OnConsumeProcessor)
54		{
55		$message = $messageProcessor->onConsume($message);
56		}
57		}
58
59		return $message;
60		}
61		}
62

puzzle-org / amqp

Pull Request — master (#29)

MessageProcessorAware::onConsume() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like