TreeHouse\Queue\Message\Message

Complexity

Total Complexity

23

Size/Duplication

Total Lines	209
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

85.25%

Importance

Changes

0

20 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	2
A	__clone()	0	5	1
A	getId()	0	4	1
A	setBody()	0	4	1
A	getBody()	0	4	1
A	setProperties()	0	4	1
A	getProperties()	0	4	1
A	setRoutingKey()	0	4	1
A	getRoutingKey()	0	4	1
A	setContentType()	0	4	1
A	getContentType()	0	4	1
A	setDeliveryMode()	0	4	1
A	getDeliveryMode()	0	4	1
A	setPriority()	0	4	1
A	getPriority()	0	4	1
A	setTimestamp()	0	4	1
A	getTimestamp()	0	4	1
A	setHeader()	0	7	1
A	getHeader()	0	10	2
A	getHeaders()	0	8	2

<?php

namespace TreeHouse\Queue\Message;

class Message
{
    /**
     * @var string
     */
    private $id;

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

    /**
     * @var MessageProperties
     */
    private $properties;

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

    /**
     * @param string                 $id
     * @param string                 $body
     * @param MessageProperties|null $properties
     * @param string|null            $routingKey
     */
    public function __construct($body, MessageProperties $properties = null, $id = null, $routingKey = null)
    {
        $this->id = $id;
        $this->body = $body;
        $this->properties = $properties ?: new MessageProperties();
        $this->routingKey = $routingKey;
    }

    /**
     * Resets id and deep-clones properties.
     */
    public function __clone()
    {
        $this->id = null;
        $this->properties = new MessageProperties($this->properties->toArray());
    }

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

    /**
     * @param string $body
     */
    public function setBody($body)
    {
        $this->body = $body;
    }

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

    /**
     * @param MessageProperties $properties
     */
    public function setProperties($properties)
    {
        $this->properties = $properties;
    }

    /**
     * @return MessageProperties
     */
    public function getProperties()
    {
        return $this->properties;
    }

    /**
     * @param string $routingKey
     */
    public function setRoutingKey($routingKey)
    {
        $this->routingKey = $routingKey;
    }

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

    /**
     * @param string $contentType
     */
    public function setContentType($contentType)
    {
        $this->properties->set(MessageProperties::KEY_CONTENT_TYPE, $contentType);
    }

    /**
     * @return string
     */
    public function getContentType()
    {
        return $this->properties->get(MessageProperties::KEY_CONTENT_TYPE);
    }

    /**
     * @param int $deliveryMode
     */
    public function setDeliveryMode($deliveryMode)
    {
        $this->properties->set(MessageProperties::KEY_DELIVERY_MODE, (integer) $deliveryMode);
    }

    /**
     * @return int
     */
    public function getDeliveryMode()
    {
        return $this->properties->get(MessageProperties::KEY_DELIVERY_MODE);
    }

    /**
     * @param int $priority
     */
    public function setPriority($priority)
    {
        $this->properties->set(MessageProperties::KEY_PRIORITY, (integer) $priority);
    }

    /**
     * @return int
     */
    public function getPriority()
    {
        return $this->properties->get(MessageProperties::KEY_PRIORITY);
    }

    /**
     * @param int $timestamp
     */
    public function setTimestamp($timestamp)
    {
        $this->properties->set(MessageProperties::KEY_TIMESTAMP, (integer) $timestamp);
    }

    /**
     * @return int
     */
    public function getTimestamp()
    {
        return $this->properties->get(MessageProperties::KEY_TIMESTAMP);
    }

    /**
     * @param string $name
     * @param mixed $value
     */
    public function setHeader($name, $value)
    {
        $headers = $this->getHeaders();
        $headers[$name] = $value;

        $this->properties[MessageProperties::KEY_HEADERS] = $headers;
    }

    /**
     * Get a specific message header.
     *
     * @param string $name Name of the header to get the value from.
     *
     * @return string|bool The contents of the specified header or false if not set.
     */
    public function getHeader($name)
    {
        $headers = $this->getHeaders();

        if (!isset($headers[$name])) {
            return false;
        }

        return $headers[$name];
    }

    /**
     * Get the headers of the message.
     *
     * @return array An array of key value pairs associated with the message.
     */
    public function getHeaders()
    {
        if (!isset($this->properties[MessageProperties::KEY_HEADERS])) {
            $this->properties[MessageProperties::KEY_HEADERS] = [];
        }

        return $this->properties[MessageProperties::KEY_HEADERS];
    }
}