Skip to content

Commit b825585

Browse files
authored
Change getQueueArguments to public and allow custom failed exchange to be passed
1 parent d6ae780 commit b825585

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -597,7 +597,7 @@ public function close(): void
597597
/**
598598
* Get the Queue arguments.
599599
*/
600-
protected function getQueueArguments(string $destination): array
600+
public function getQueueArguments(string $destination, ?string $failedExchange = null): array
601601
{
602602
$arguments = [];
603603

@@ -610,7 +610,7 @@ protected function getQueueArguments(string $destination): array
610610
}
611611

612612
if ($this->getRabbitMQConfig()->isRerouteFailed()) {
613-
$arguments['x-dead-letter-exchange'] = $this->getFailedExchange();
613+
$arguments['x-dead-letter-exchange'] = $this->getFailedExchange($failedExchange);
614614
$arguments['x-dead-letter-routing-key'] = $this->getFailedRoutingKey($destination);
615615
}
616616

0 commit comments

Comments
 (0)