Puzzle\AMQP\Clients\Processors\MessageProcessorAware

Complexity

Total Complexity

10

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setMessageProcessors()	0	14	3
A	appendMessageProcessor()	0	6	1
A	onPublish()	0	10	3
A	onConsume()	0	12	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;
    }
}