Puzzle\AMQP\Messages\Processors\AddHeader

Complexity

Total Complexity

5

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addHeader()	0	6	1
A	onPublish()	0	12	3

<?php

namespace Puzzle\AMQP\Messages\Processors;

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

class AddHeader implements Processor
{
    private
        $headers;
    
    public function __construct(array $headers = [])
    {
        $this->headers = $headers;
    }
    
    public function addHeader($name, $value)
    {
        $this->headers[$name] = $value;
        
        return $this;
    }
        
    public function onPublish(WritableMessage $message)
    {
        $alreadySetHeaders = $message->getHeaders();
        
        foreach($this->headers as $header => $value)
        {
            if(! isset($alreadySetHeaders[$header]))
            {
                $message->addHeader($header, $value);
            }
        }
    }
}