Mouf\AmqpClient\Objects\Message

Complexity

Total Complexity

33

Size/Duplication

Total Lines	376
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	2
Bugs	1	Features	0

32 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getBody()	0	4	1
A	getContentType()	0	4	1
A	setContentType()	0	5	1
A	getContentEncoding()	0	4	1
A	setContentEncoding()	0	5	1
A	getApplicationHeaders()	0	4	1
A	setApplicationHeaders()	0	5	1
A	getDeliveryMode()	0	4	1
A	setDeliveryMode()	0	5	1
A	getPriority()	0	4	1
A	setPriority()	0	5	1
A	getCorrelationId()	0	4	1
A	setCorrelationId()	0	5	1
A	getReplyTo()	0	4	1
A	setReplyTo()	0	5	1
A	getExpiration()	0	4	1
A	setExpiration()	0	5	1
A	getMessageId()	0	4	1
A	setMessageId()	0	5	1
A	getTimestamp()	0	4	1
A	setTimestamp()	0	5	1
A	getType()	0	4	1
A	setType()	0	5	1
A	getUserId()	0	4	1
A	setUserId()	0	5	1
A	getAppId()	0	4	1
A	setAppId()	0	5	1
A	getClusterId()	0	4	1
A	setClusterId()	0	5	1
A	toAMQPMessage()	0	21	1
A	fillParameters()	0	6	2

<?php

namespace Mouf\AmqpClient\Objects;

use PhpAmqpLib\Message\AMQPMessage;

/**
 * A message sent to RabbitMQ.
 *
 * Note: by default, those message are set to "persistent delivery mode"
 */
class Message
{
    private $body;

    /**
     * @var string
     */
    private $content_type;

    /**
     * @var string
     */
    private $content_encoding;

    /**
     * @var array
     */
    private $application_headers;

    /**
     * @var int
     */
    private $delivery_mode = AMQPMessage::DELIVERY_MODE_PERSISTENT;

    /**
     * @var int
     */
    private $priority;

    /**
     * @var string
     */
    private $correlation_id;

    /**
     * @var string
     */
    private $reply_to;

    /**
     * @var string
     */
    private $expiration;

    /**
     * @var string
     */
    private $message_id;

    /**
     * @var \DateTimeInterface
     */
    private $timestamp;

    /**
     * @var string
     */
    private $type;

    /**
     * @var string
     */
    private $user_id;

    /**
     * @var string
     */
    private $app_id;

    /**
     * @var string
     */
    private $cluster_id;

    /**
     * Message constructor.
     *
     * @param string $body
     */
    public function __construct($body)
    {
        $this->body = $body;
    }

    /**
     * @return string
     */
    public function getBody()
    {
        return $this->body;
    }

    /**
     * @return string
     */
    public function getContentType()
    {
        return $this->content_type;
    }

    /**
     * @param string $content_type
     * @return Message
     */
    public function setContentType($content_type)
    {
        $this->content_type = $content_type;
        return $this;
    }

    /**
     * @return string
     */
    public function getContentEncoding()
    {
        return $this->content_encoding;
    }

    /**
     * @param string $content_encoding
     * @return Message
     */
    public function setContentEncoding($content_encoding)
    {
        $this->content_encoding = $content_encoding;
        return $this;
    }

    /**
     * @return array
     */
    public function getApplicationHeaders()
    {
        return $this->application_headers;
    }

    /**
     * @param array $application_headers
     * @return Message
     */
    public function setApplicationHeaders($application_headers)
    {
        $this->application_headers = $application_headers;
        return $this;
    }

    /**
     * @return int
     */
    public function getDeliveryMode()
    {
        return $this->delivery_mode;
    }

    /**
     * @param int $delivery_mode
     * @return Message
     */
    public function setDeliveryMode($delivery_mode)
    {
        $this->delivery_mode = $delivery_mode;
        return $this;
    }

    /**
     * @return int
     */
    public function getPriority()
    {
        return $this->priority;
    }

    /**
     * @param int $priority
     * @return Message
     */
    public function setPriority($priority)
    {
        $this->priority = $priority;
        return $this;
    }

    /**
     * @return string
     */
    public function getCorrelationId()
    {
        return $this->correlation_id;
    }

    /**
     * @param string $correlation_id
     * @return Message
     */
    public function setCorrelationId($correlation_id)
    {
        $this->correlation_id = $correlation_id;
        return $this;
    }

    /**
     * @return string
     */
    public function getReplyTo()
    {
        return $this->reply_to;
    }

    /**
     * @param string $reply_to
     * @return Message
     */
    public function setReplyTo($reply_to)
    {
        $this->reply_to = $reply_to;
        return $this;
    }

    /**
     * @return string
     */
    public function getExpiration()
    {
        return $this->expiration;
    }

    /**
     * @param string $expiration
     * @return Message
     */
    public function setExpiration($expiration)
    {
        $this->expiration = $expiration;
        return $this;
    }

    /**
     * @return string
     */
    public function getMessageId()
    {
        return $this->message_id;
    }

    /**
     * @param string $message_id
     * @return Message
     */
    public function setMessageId($message_id)
    {
        $this->message_id = $message_id;
        return $this;
    }

    /**
     * @return \DateTimeInterface
     */
    public function getTimestamp()
    {
        return $this->timestamp;
    }

    /**
     * @param \DateTimeInterface $timestamp
     * @return Message
     */
    public function setTimestamp($timestamp)
    {
        $this->timestamp = $timestamp;
        return $this;
    }

    /**
     * @return string
     */
    public function getType()
    {
        return $this->type;
    }

    /**
     * @param string $type
     * @return Message
     */
    public function setType($type)
    {
        $this->type = $type;
        return $this;
    }

    /**
     * @return string
     */
    public function getUserId()
    {
        return $this->user_id;
    }

    /**
     * @param string $user_id
     * @return Message
     */
    public function setUserId($user_id)
    {
        $this->user_id = $user_id;
        return $this;
    }

    /**
     * @return string
     */
    public function getAppId()
    {
        return $this->app_id;
    }

    /**
     * @param string $app_id
     * @return Message
     */
    public function setAppId($app_id)
    {
        $this->app_id = $app_id;
        return $this;
    }

    /**
     * @return string
     */
    public function getClusterId()
    {
        return $this->cluster_id;
    }

    /**
     * @param string $cluster_id
     * @return Message
     */
    public function setClusterId($cluster_id)
    {
        $this->cluster_id = $cluster_id;
        return $this;
    }

    /**
     * @return AMQPMessage
     */
    public function toAMQPMessage()
    {
        $parameters = [];
        $this->fillParameters('content_type', $parameters);
        $this->fillParameters('content_encoding', $parameters);
        $this->fillParameters('application_headers', $parameters);
        $this->fillParameters('delivery_mode', $parameters);
        $this->fillParameters('priority', $parameters);
        $this->fillParameters('correlation_id', $parameters);
        $this->fillParameters('reply_to', $parameters);
        $this->fillParameters('expiration', $parameters);
        $this->fillParameters('message_id', $parameters);
        $this->fillParameters('timestamp', $parameters);
        $this->fillParameters('type', $parameters);
        $this->fillParameters('user_id', $parameters);
        $this->fillParameters('app_id', $parameters);
        $this->fillParameters('cluster_id', $parameters);

        $amqpMessage = new AMQPMessage($this->body, $parameters);
        return $amqpMessage;
    }

    private function fillParameters($parameterName, &$parameters)
    {
        if ($this->$parameterName !== null) {
            $parameters[$parameterName] = $this->$parameterName;
        }
    }
}