vendor/enqueue/dbal/DbalMessage.php line 9

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Enqueue\Dbal;
  7. use Interop\Queue\Message;
  9. class DbalMessage implements Message
  10. {
  11.     /**
  12.      * @var string
  13.      */
  14.     private $body;
  16.     /**
  17.      * @var array
  18.      */
  19.     private $properties;
  21.     /**
  22.      * @var array
  23.      */
  24.     private $headers;
  26.     /**
  27.      * @var bool
  28.      */
  29.     private $redelivered;
  31.     /**
  32.      * @var int
  33.      */
  34.     private $priority;
  36.     /**
  37.      * @var int milliseconds
  38.      */
  39.     private $deliveryDelay;
  41.     /**
  42.      * @var int seconds
  43.      */
  44.     private $redeliverAfter;
  46.     /**
  47.      * @var int milliseconds
  48.      */
  49.     private $timeToLive;
  51.     /**
  52.      * @var string|null
  53.      */
  54.     private $deliveryId;
  56.     /**
  57.      * @var string|null
  58.      */
  59.     private $queue;
  61.     /**
  62.      * Milliseconds, for example 15186054527288.
  63.      *
  64.      * Could be generated by the code: (int) (microtime(true) * 10000)
  65.      *
  66.      * @var int
  67.      */
  68.     private $publishedAt;
  70.     /**
  71.      * @param string $body
  72.      * @param array  $properties
  73.      * @param array  $headers
  74.      */
  75.     public function __construct(string $body = '', array $properties = [], array $headers = [])
  76.     {
  77.         $this->body = $body;
  78.         $this->properties = $properties;
  79.         $this->headers = $headers;
  80.         $this->redelivered = false;
  81.         $this->priority = null;
  82.         $this->deliveryDelay = null;
  83.         $this->deliveryId = null;
  84.         $this->redeliverAfter = null;
  85.     }
  87.     public function setBody(string $body): void
  88.     {
  89.         $this->body = $body;
  90.     }
  92.     public function getBody(): string
  93.     {
  94.         return $this->body;
  95.     }
  97.     public function setProperties(array $properties): void
  98.     {
  99.         $this->properties = $properties;
  100.     }
  102.     public function setProperty(string $name, $value): void
  103.     {
  104.         $this->properties[$name] = $value;
  105.     }
  107.     public function getProperties(): array
  108.     {
  109.         return $this->properties;
  110.     }
  112.     public function getProperty(string $name, $default = null)
  113.     {
  114.         return array_key_exists($name, $this->properties) ? $this->properties[$name] : $default;
  115.     }
  117.     public function setHeader(string $name, $value): void
  118.     {
  119.         $this->headers[$name] = $value;
  120.     }
  122.     public function setHeaders(array $headers): void
  123.     {
  124.         $this->headers = $headers;
  125.     }
  127.     public function getHeaders(): array
  128.     {
  129.         return $this->headers;
  130.     }
  132.     public function getHeader(string $name, $default = null)
  133.     {
  134.         return array_key_exists($name, $this->headers) ? $this->headers[$name] : $default;
  135.     }
  137.     public function isRedelivered(): bool
  138.     {
  139.         return $this->redelivered;
  140.     }
  142.     public function setRedelivered(bool $redelivered): void
  143.     {
  144.         $this->redelivered = $redelivered;
  145.     }
  147.     public function setReplyTo(string $replyTo = null): void
  148.     {
  149.         $this->setHeader('reply_to', $replyTo);
  150.     }
  152.     public function getReplyTo(): ?string
  153.     {
  154.         return $this->getHeader('reply_to');
  155.     }
  157.     public function getPriority(): ?int
  158.     {
  159.         return $this->priority;
  160.     }
  162.     public function setPriority(int $priority = null): void
  163.     {
  164.         $this->priority = $priority;
  165.     }
  167.     public function getDeliveryDelay(): ?int
  168.     {
  169.         return $this->deliveryDelay;
  170.     }
  172.     /**
  173.      * Set delay in milliseconds.
  174.      */
  175.     public function setDeliveryDelay(int $deliveryDelay = null): void
  176.     {
  177.         $this->deliveryDelay = $deliveryDelay;
  178.     }
  180.     /**
  181.      * @return int
  182.      */
  183.     public function getTimeToLive(): ?int
  184.     {
  185.         return $this->timeToLive;
  186.     }
  188.     /**
  189.      * Set time to live in milliseconds.
  190.      */
  191.     public function setTimeToLive(int $timeToLive = null): void
  192.     {
  193.         $this->timeToLive = $timeToLive;
  194.     }
  196.     public function setCorrelationId(string $correlationId = null): void
  197.     {
  198.         $this->setHeader('correlation_id', $correlationId);
  199.     }
  201.     public function getCorrelationId(): ?string
  202.     {
  203.         return $this->getHeader('correlation_id', null);
  204.     }
  206.     public function setMessageId(string $messageId = null): void
  207.     {
  208.         $this->setHeader('message_id', $messageId);
  209.     }
  211.     public function getMessageId(): ?string
  212.     {
  213.         return $this->getHeader('message_id', null);
  214.     }
  216.     public function getTimestamp(): ?int
  217.     {
  218.         $value = $this->getHeader('timestamp');
  220.         return null === $value ? null : $value;
  221.     }
  223.     public function setTimestamp(int $timestamp = null): void
  224.     {
  225.         $this->setHeader('timestamp', $timestamp);
  226.     }
  228.     public function getDeliveryId(): ?string
  229.     {
  230.         return $this->deliveryId;
  231.     }
  233.     public function setDeliveryId(?string $deliveryId = null): void
  234.     {
  235.         $this->deliveryId = $deliveryId;
  236.     }
  238.     public function getRedeliverAfter(): int
  239.     {
  240.         return $this->redeliverAfter;
  241.     }
  243.     public function setRedeliverAfter(int $redeliverAfter = null): void
  244.     {
  245.         $this->redeliverAfter = $redeliverAfter;
  246.     }
  248.     public function getPublishedAt(): ?int
  249.     {
  250.         return $this->publishedAt;
  251.     }
  253.     public function setPublishedAt(int $publishedAt = null): void
  254.     {
  255.         $this->publishedAt = $publishedAt;
  256.     }
  258.     public function getQueue(): ?string
  259.     {
  260.         return $this->queue;
  261.     }
  263.     public function setQueue(?string $queue): void
  264.     {
  265.         $this->queue = $queue;
  266.     }
  267. }