From bc7ee359dfe4e66a05c2cca9deb7a945534009f3 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 20 十月 2023 18:30:26 +0800
Subject: [PATCH] 删除不再用的topic，增加初始化的时候，设备拉取
---
nsq/nsq.go | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/nsq/nsq.go b/nsq/nsq.go
index a64f1b0..c2eb366 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -34,7 +34,6 @@
var topics = []string{
constvar.NsqTopicScheduleTask,
constvar.NsqTopicSendPlcAddress,
- constvar.NsqTopicProcessParamsResponse,
constvar.NsqTopicApsProcessParams,
constvar.NsqTopicDeviceUpdate,
constvar.NsqTopicPullDataResponse,
@@ -73,7 +72,9 @@
if consumer, ok := value.(*nsqclient.NsqConsumer); ok {
nsqclient.DestroyNsqConsumer(consumer)
logx.Infof("try stop consumer, topic : %v", key)
+ consumer = nil
}
+
return true
})
}
--
Gitblit v1.8.0