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

Completed

Pull Request — master (#29)

by Nicolas

created 2017-04-02 19:03 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	8
CRAP Score	3

Importance

Changes

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

<?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		private
14		$messageProcessors = [];
15
16	2	public function setMessageProcessors(array $processors)
17		{
18	2	$this->messageProcessors = [];
19
20	2	foreach($processors as $processor)
21		{
22	2	if($processor instanceof Processor)
23	2	{
24	2	$this->appendMessageProcessor($processor);
25	2	}
26	2	}
27
28	2	return $this;
29		}
30
31	6	public function appendMessageProcessor(Processor $processor)
32		{
33	6	$this->messageProcessors[] = $processor;
34
35	6	return $this;
36		}
37
38	13	private function onPublish(WritableMessage $message)
39		{
40	13	foreach($this->messageProcessors as $messageProcessor)
41		{
42	5	if($messageProcessor instanceof OnPublishProcessor)
43	5	{
44	2	$messageProcessor->onPublish($message);
45	2	}
46	13	}
47	13	}
48
49	2	private function onConsume(ReadableMessage $message)
50		{
51	2	foreach(array_reverse($this->messageProcessors) as $messageProcessor)
52		{
53	1	if($messageProcessor instanceof OnConsumeProcessor)
54	1	{
55	1	$message = $messageProcessor->onConsume($message);
56	1	}
57	2	}
58
59	2	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