for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?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]);
* @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;