Puzzle\AMQP\Messages\InMemory::build()

Complexity

Conditions	2
Paths	2

Size

Total Lines	24
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    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)
        );
    }
}