vendor/sroze/messenger-enqueue-transport/EnvelopeItem/TransportConfiguration.php line 24

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Enqueue\MessengerAdapter\EnvelopeItem;
  14. use Enqueue\AmqpTools\DelayStrategy;
  15. use Symfony\Component\Messenger\Stamp\StampInterface;
  17. /**
  18.  * Message envelope item allowing to specify some transport configuration.
  19.  *
  20.  * @author       Thomas Prelot <tprelot@gmail.com>
  21.  *
  22.  * @experimental in 4.1
  23.  */
  24. final class TransportConfiguration implements StampInterface, \Serializable
  25. {
  26.     private $topic;
  28.     private $metadata = array();
  30.     public function __construct(array $configuration = array())
  31.     {
  32.         $this->topic = $configuration['topic'] ?? null;
  33.         $this->metadata = $configuration['metadata'] ?? array();
  34.     }
  36.     /**
  37.      * Get topic name.
  38.      */
  39.     public function getTopic(): ?string
  40.     {
  41.         return $this->topic;
  42.     }
  44.     /**
  45.      * Retrieve metadata information for decorating
  46.      * concrete implementations of Interop\Queue\Message.
  47.      */
  48.     public function getMetadata(): array
  49.     {
  50.         return $this->metadata;
  51.     }
  53.     public function setTopic($topic): self
  54.     {
  55.         $this->topic = $topic;
  57.         return $this;
  58.     }
  60.     public function setMetadata(array $metadata): self
  61.     {
  62.         $this->metadata = $metadata;
  64.         return $this;
  65.     }
  67.     public function addMetadata(string $key, $value): self
  68.     {
  69.         $this->metadata[$key] = $value;
  71.         return $this;
  72.     }
  74.     public function setPriority(int $priority = null): self
  75.     {
  76.         $this->metadata['priority'] = $priority;
  78.         return $this;
  79.     }
  81.     public function setDeliveryDelay(int $deliveryDelay = null): self
  82.     {
  83.         $this->metadata['deliveryDelay'] = $deliveryDelay;
  85.         return $this;
  86.     }
  88.     public function setDelayStrategy(DelayStrategy $delayStrategy = null): self
  89.     {
  90.         $this->metadata['delayStrategy'] = $delayStrategy;
  92.         return $this;
  93.     }
  95.     public function setTimeToLive(int $timeToLive = null): self
  96.     {
  97.         $this->metadata['timeToLive'] = $timeToLive;
  99.         return $this;
  100.     }
  102.     public function serialize()
  103.     {
  104.         return serialize(array(
  105.             'topic' => $this->topic,
  106.             'metadata' => $this->metadata,
  107.         ));
  108.     }
  110.     public function unserialize($serialized)
  111.     {
  112.         list(
  113.             'topic' => $topic,
  114.             'metadata' => $metadata
  115.         ) = unserialize($serialized, array('allowed_classes' => false));
  117.         $this->__construct(array(
  118.             'topic' => $topic,
  119.             'metadata' => $metadata,
  120.         ));
  121.     }
  122. }