From b8255853422e77f633753cac269a2c8ea4a58433 Mon Sep 17 00:00:00 2001 From: Frederik Sauer Date: Tue, 18 Nov 2025 11:47:55 +0100 Subject: [PATCH] Change getQueueArguments to public and allow custom failed exchange to be passed --- src/Queue/RabbitMQQueue.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Queue/RabbitMQQueue.php b/src/Queue/RabbitMQQueue.php index 04377a0d..2aa264e2 100644 --- a/src/Queue/RabbitMQQueue.php +++ b/src/Queue/RabbitMQQueue.php @@ -597,7 +597,7 @@ public function close(): void /** * Get the Queue arguments. */ - protected function getQueueArguments(string $destination): array + public function getQueueArguments(string $destination, ?string $failedExchange = null): array { $arguments = []; @@ -610,7 +610,7 @@ protected function getQueueArguments(string $destination): array } if ($this->getRabbitMQConfig()->isRerouteFailed()) { - $arguments['x-dead-letter-exchange'] = $this->getFailedExchange(); + $arguments['x-dead-letter-exchange'] = $this->getFailedExchange($failedExchange); $arguments['x-dead-letter-routing-key'] = $this->getFailedRoutingKey($destination); }