Skip to content

Commit 94e15ad

Browse files
author
anonim
committed
Fix: remove $config from RabbitMQQueue
1 parent d06427b commit 94e15ad

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ class RabbitMQQueue extends Queue implements QueueContract, RabbitMQQueueContrac
4848
* List of already declared queues.
4949
*/
5050
protected array $queues = [];
51-
51+
5252
/**
5353
* List of already bound queues to exchanges.
5454
*/
@@ -62,15 +62,15 @@ class RabbitMQQueue extends Queue implements QueueContract, RabbitMQQueueContrac
6262
/**
6363
* Holds the Configuration
6464
*/
65-
protected QueueConfig $config;
65+
protected QueueConfig $rabbitQueueConfig;
6666

6767
/**
6868
* RabbitMQQueue constructor.
6969
*/
70-
public function __construct(QueueConfig $config)
70+
public function __construct(QueueConfig $rabbitQueueConfig)
7171
{
72-
$this->config = $config;
73-
$this->dispatchAfterCommit = $config->isDispatchAfterCommit();
72+
$this->rabbitQueueConfig = $rabbitQueueConfig;
73+
$this->dispatchAfterCommit = $rabbitQueueConfig->isDispatchAfterCommit();
7474
}
7575

7676
/**
@@ -735,9 +735,9 @@ protected function publishProperties($queue, array $options = []): array
735735
return [$destination, $exchange, $exchangeType, $attempts];
736736
}
737737

738-
protected function getConfig(): QueueConfig
738+
public function getConfig(): QueueConfig
739739
{
740-
return $this->config;
740+
return $this->rabbitQueueConfig;
741741
}
742742

743743
/**

0 commit comments

Comments
 (0)