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; } /**