Puzzle\AMQP\Messages\InMemory

Complexity

Total Complexity

2

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	build()	0	24	2

<?php

namespace Puzzle\AMQP\Messages;

use Puzzle\AMQP\Workers\MessageAdapter;
use Puzzle\AMQP\Messages\Bodies\NullBody;

class InMemory
{
    /**
     * @return \Puzzle\AMQP\ReadableMessage
     */
    public static function build($routingKey, Body $body = null, array $additionalHeaders = [], array $additionalAttributes = [])
    {
        if(! $body instanceof Body)
        {
            $body = new NullBody();
        }

        $attributes = array_merge([
            'content_type' => $body->getContentType(),
            'routing_key' => $routingKey,
            'content_encoding' => 'utf8',
            'message_id' => uniqid(true),
        ], $additionalAttributes);

        $attributes['headers'] = array_merge([
            'routing_key' => $routingKey,
            'app_id' => 'memory',
            'message_datetime' => date('Y-m-d H:i:s'),
        ], $additionalHeaders);

        return new MessageAdapter(
            new \Swarrot\Broker\Message($body->format(), $attributes)
        );
    }
}