From 7276ab65576ec73b439a40d7f1a3035a534b968c Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 20 十月 2023 19:12:40 +0800
Subject: [PATCH] 停止消费时关闭tcp连接
---
nsq/nsq.go | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
diff --git a/nsq/nsq.go b/nsq/nsq.go
index c2eb366..06e78e5 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -73,8 +73,8 @@
nsqclient.DestroyNsqConsumer(consumer)
logx.Infof("try stop consumer, topic : %v", key)
consumer = nil
+ c.clients.Delete(key)
}
-
return true
})
}
--
Gitblit v1.8.0