Kaliop\Queueing\Plugins\KinesisBundle\Adapter\Kinesis\Message

Complexity

Total Complexity

7

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getBody()	0	4	1
A	getContentType()	0	4	1
A	has()	0	4	1
A	get()	0	4	1
A	getProperties()	0	4	1
A	getQueueName()	0	4	1

<?php

namespace Kaliop\Queueing\Plugins\KinesisBundle\Adapter\Kinesis;

use Kaliop\QueueingBundle\Queue\MessageInterface;

class Message implements MessageInterface
{
    protected $body;
    protected $properties = array();
    protected $contentType;
    protected $streamName;

    public function __construct($body, array $properties = array(), $contentType='application/json', $queueName='')
    {
        $this->body = $body;
        $this->properties = $properties;
        $this->contentType = $contentType;
        $this->streamName = $queueName;
    }

    public function getBody()
    {
        return $this->body;
    }

    /**
     * This is hardcoded because
     * @return string
     */
    public function getContentType()
    {
        return $this->contentType;
    }

    /**
     * Check whether a property exists in the 'properties' dictionary
     * @param string $name
     * @return bool
     */
    public function has($name)
    {
        return isset($this->properties[$name]);
    }

    /**
     * @param string $name
     * @throws \OutOfBoundsException
     * @return mixed
     */
    public function get($name)
    {
        return $this->properties[$name];
    }

    /**
     * Returns the properties content
     * @return array
     */
    public function getProperties()
    {
        return $this->properties;
    }

    public function getQueueName()
    {
        return $this->streamName;
    }
}