We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7bf2015 commit 3b5f250Copy full SHA for 3b5f250
1 file changed
src/Driver/RedisQueue.php
@@ -31,9 +31,10 @@ public function __construct(Config|ClusterConfig $config)
31
32
public function init(string $topicName, ?string $nodeId): bool
33
{
34
- if(!$this->hasInit){
35
- $this->hasInit = true;
+ if($this->hasInit){
+ return true;
36
}
37
+ $this->hasInit = true;
38
$this->queueName = $topicName;
39
$this->pool = new _Pool($this->config);
40
return true;
@@ -172,6 +173,8 @@ public function flush():bool
172
173
174
public function __clone()
175
-
176
+ if($this->pool){
177
+ $this->pool = clone $this->pool;
178
+ }
179
180
0 commit comments