fix renew bug

easy-swoole · Aug 16, 2023 · 7b6fca4 · 7b6fca4
1 parent ba9f7d6
commit 7b6fca4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Queue.php b/src/Queue.php
@@ -28,7 +28,7 @@ function queueDriver():QueueDriverInterface
 
     function consumer(string $topic,bool $renew = false):Consumer
     {
-        if((!$renew) || !isset($this->consumer[$topic])){
+        if(($renew) || !isset($this->consumer[$topic])){
             $driver = clone $this->driver;
             if(!$driver->init($topic,$this->nodeId)){
                 throw new Exception("init queue topic:{$topic} driver fail");