Merge pull request #17 from kafkiansky/feature/durable-queue

Allow to define durable queue info property
roadrunner-php · May 25, 2022 · 4008783 · 4008783
2 parents cf4f701 + 332a4d1
commit 4008783
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/src/Queue/AMQPCreateInfo.php b/src/Queue/AMQPCreateInfo.php
@@ -63,6 +63,11 @@ final class AMQPCreateInfo extends CreateInfo
      */
     public const REQUEUE_ON_FAIL_DEFAULT_VALUE = false;
 
+    /**
+     * @var bool
+     */
+    public const DURABLE_DEFAULT_VALUE = false;
+
     /**
      * @var positive-int
      */
@@ -103,6 +108,11 @@ final class AMQPCreateInfo extends CreateInfo
      */
     public bool $requeueOnFail = self::REQUEUE_ON_FAIL_DEFAULT_VALUE;
 
+    /**
+     * @var bool
+     */
+    public bool $durable = self::DURABLE_DEFAULT_VALUE;
+
     /**
      * @param non-empty-string $name
      * @param positive-int $priority
@@ -114,6 +124,7 @@ final class AMQPCreateInfo extends CreateInfo
      * @param bool $exclusive
      * @param bool $multipleAck
      * @param bool $requeueOnFail
+     * @param bool $durable
      */
     public function __construct(
         string $name,
@@ -125,7 +136,8 @@ public function __construct(
         string $routingKey = self::ROUTING_KEY_DEFAULT_VALUE,
         bool $exclusive = self::EXCLUSIVE_DEFAULT_VALUE,
         bool $multipleAck = self::MULTIPLE_ACK_DEFAULT_VALUE,
-        bool $requeueOnFail = self::REQUEUE_ON_FAIL_DEFAULT_VALUE
+        bool $requeueOnFail = self::REQUEUE_ON_FAIL_DEFAULT_VALUE,
+        bool $durable = self::DURABLE_DEFAULT_VALUE
     ) {
         parent::__construct(Driver::AMQP, $name, $priority);
 
@@ -142,6 +154,7 @@ public function __construct(
         $this->exclusive = $exclusive;
         $this->multipleAck = $multipleAck;
         $this->requeueOnFail = $requeueOnFail;
+        $this->durable = $durable;
     }
 
     /**
@@ -158,6 +171,7 @@ public function toArray(): array
             'exclusive'       => $this->exclusive,
             'multiple_ack'    => $this->multipleAck,
             'requeue_on_fail' => $this->requeueOnFail,
+            'durable'         => $this->durable,
         ]);
     }
 }