From 578b74f9de4b96e88e2fddb726c7c6f78162b033 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 21 十月 2023 14:34:23 +0800
Subject: [PATCH] 启停生产者
---
nsq/nsq.go | 9 ++-------
1 files changed, 2 insertions(+), 7 deletions(-)
diff --git a/nsq/nsq.go b/nsq/nsq.go
index 18fa6ce..3887253 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -23,17 +23,12 @@
defaultConsumerManager = new(consumerManager)
}
-var producerStarted bool
-
func (c *consumerManager) init() error {
if len(conf.Conf.NsqConf.NodeId) <= 0 {
return errors.New("no NodeId")
}
- if !producerStarted {
- if err := initProducer(); err != nil {
- return err
- }
- producerStarted = true
+ if err := initProducer(); err != nil {
+ return err
}
var topics = []string{
constvar.NsqTopicScheduleTask,
--
Gitblit v1.8.0