From c742b8885122ee292b61d70cec7b7c284b1e555b Mon Sep 17 00:00:00 2001 From: Bradley MacGregor Date: Thu, 25 Sep 2025 11:51:31 -0600 Subject: [PATCH 1/2] Allow setting of queue name Unlike, perhaps, most queues, AMQP allows empty string for an initial queue name, which is then replaced with an automatically generated queue name. For this reason, we need this public function. --- src/AmqpQueue.php | 2 ++ src/Impl/AmqpQueue.php | 5 +++++ 2 files changed, 7 insertions(+) diff --git a/src/AmqpQueue.php b/src/AmqpQueue.php index dd98fb4..0772a18 100644 --- a/src/AmqpQueue.php +++ b/src/AmqpQueue.php @@ -29,4 +29,6 @@ public function getArgument(string $key); public function getConsumerTag(): ?string; public function setConsumerTag(?string $consumerTag = null): void; + + public function setQueueName(string $queueName): void; } diff --git a/src/Impl/AmqpQueue.php b/src/Impl/AmqpQueue.php index d0c8048..bb71b34 100644 --- a/src/Impl/AmqpQueue.php +++ b/src/Impl/AmqpQueue.php @@ -40,6 +40,11 @@ public function getQueueName(): string return $this->name; } + public function setQueueName(?string $queueName): void + { + $this->name = $queueName; + } + public function getConsumerTag(): ?string { return $this->consumerTag; From 6b1a65dd540ac80141f9f4af0aea1b30a15f5102 Mon Sep 17 00:00:00 2001 From: avatarofhope2 Date: Thu, 25 Sep 2025 12:56:23 -0600 Subject: [PATCH 2/2] Update AmqpQueue.php Correction to indentation. --- src/Impl/AmqpQueue.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Impl/AmqpQueue.php b/src/Impl/AmqpQueue.php index bb71b34..6f5b526 100644 --- a/src/Impl/AmqpQueue.php +++ b/src/Impl/AmqpQueue.php @@ -42,7 +42,7 @@ public function getQueueName(): string public function setQueueName(?string $queueName): void { - $this->name = $queueName; + $this->name = $queueName; } public function getConsumerTag(): ?string