message.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\Message;
 
use Bitrix\Calendar\Core;
 
class Message implements Core\Queue\Interfaces\Message, Core\Base\EntityInterface
{
    private array $body = [];
    private array $headers = [];
    private array $properties = [];
    private ?int $id = null;
 
    public function setId(?int $id): Message
    {
        $this->id = $id;
 
        return $this;
    }
 
    public function getId(): ?int
    {
        return $this->id;
    }
 
    public function getBody(): array
    {
        return $this->body;
    }
 
    public function setBody($body): self
    {
        $this->body = $body;
 
        return $this;
    }
 
    public function setProperties(array $properties): self
    {
        $this->properties = $properties;
 
        return $this;
    }
 
    public function setProperty(string $name, $value): self
    {
        $this->properties[$name] = $value;
 
        return $this;
    }
 
    public function getProperties(): array
    {
        return $this->properties;
    }
 
    public function getProperty(string $name, $default = null)
    {
        return array_key_exists($name, $this->properties)
            ? $this->properties[$name]
            : $default
        ;
    }
 
    public function setHeader(string $name, $value): self
    {
        $this->headers[$name] = $value;
 
        return $this;
    }
 
    public function setHeaders(array $headers): self
    {
        $this->headers = $headers;
 
        return $this;
    }
 
    public function getHeaders(): array
    {
        return $this->headers;
    }
 
    public function getHeader(string $name, $default = null)
    {
        return array_key_exists($name, $this->headers)
            ? $this->headers[$name]
            : $default
        ;
    }
 
    public function setRoutingKey(string $routingKey = null): self
    {
        $this->setHeader('routingKey', $routingKey);
 
        return $this;
    }
 
    public function getRoutingKey(): ?string
    {
        return $this->getHeader('routingKey');
    }
}