From 7b6fca46e776b01ce1e47348dcd836b2fb6d8392 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=A6=82=E6=9E=9C=E7=9A=84=E5=A6=82=E6=9E=9C?=
 <admin@fosuss.com>
Date: Wed, 16 Aug 2023 10:23:19 +0800
Subject: [PATCH] fix renew bug

---
 src/Queue.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Queue.php b/src/Queue.php
index 34e20e2..c928355 100644
--- 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");