Jellyfish\QueueRabbitMq\AmqpMessageFactory

Complexity

Total Complexity

2

Size/Duplication

Total Lines	19
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	3	1
A	getDefaultProperties()	0	4	1

<?php

declare(strict_types=1);

namespace Jellyfish\QueueRabbitMq;

use PhpAmqpLib\Message\AMQPMessage;

class AmqpMessageFactory implements AmqpMessageFactoryInterface
{
    /**
     * @param string $body
     *
     * @return \PhpAmqpLib\Message\AMQPMessage
     */
    public function create(string $body): AMQPMessage
    {
        return new AMQPMessage($body, $this->getDefaultProperties());
    }

    /**
     * @return array
     */
    protected function getDefaultProperties(): array
    {
        return [
            'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT
        ];
    }
}