Puzzle\AMQP\Clients\Processors\MessageProcessorAware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	onPublish()	0	7	2
A	appendMessageProcessor()	0	6	1

<?php

namespace Puzzle\AMQP\Clients\Processors;

use Puzzle\AMQP\Messages\Processor;
use Puzzle\AMQP\WritableMessage;

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