From 94e15ade881b02fda4b581ba9dfbd3e8f56a1a1a Mon Sep 17 00:00:00 2001 From: anonim Date: Sat, 25 Oct 2025 19:57:06 +0500 Subject: [PATCH] Fix: remove $config from RabbitMQQueue --- src/Queue/RabbitMQQueue.php | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/Queue/RabbitMQQueue.php b/src/Queue/RabbitMQQueue.php index fadedce5..c992ae0e 100644 --- a/src/Queue/RabbitMQQueue.php +++ b/src/Queue/RabbitMQQueue.php @@ -48,7 +48,7 @@ class RabbitMQQueue extends Queue implements QueueContract, RabbitMQQueueContrac * List of already declared queues. */ protected array $queues = []; - + /** * List of already bound queues to exchanges. */ @@ -62,15 +62,15 @@ class RabbitMQQueue extends Queue implements QueueContract, RabbitMQQueueContrac /** * Holds the Configuration */ - protected QueueConfig $config; + protected QueueConfig $rabbitQueueConfig; /** * RabbitMQQueue constructor. */ - public function __construct(QueueConfig $config) + public function __construct(QueueConfig $rabbitQueueConfig) { - $this->config = $config; - $this->dispatchAfterCommit = $config->isDispatchAfterCommit(); + $this->rabbitQueueConfig = $rabbitQueueConfig; + $this->dispatchAfterCommit = $rabbitQueueConfig->isDispatchAfterCommit(); } /** @@ -735,9 +735,9 @@ protected function publishProperties($queue, array $options = []): array return [$destination, $exchange, $exchangeType, $attempts]; } - protected function getConfig(): QueueConfig + public function getConfig(): QueueConfig { - return $this->config; + return $this->rabbitQueueConfig; } /**