fix renew bug

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