From fef42313bbe5d67b9ae8929167472f95dcb0fa55 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 20 十月 2023 19:29:36 +0800
Subject: [PATCH] 只启动一次生产者
---
nsq/nsq.go | 10 +++++++---
1 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/nsq/nsq.go b/nsq/nsq.go
index 06e78e5..3561a25 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -23,14 +23,18 @@
defaultConsumerManager = new(consumerManager)
}
+var producerStarted bool
+
func (c *consumerManager) init() error {
if len(conf.Conf.NsqConf.NodeId) <= 0 {
return errors.New("no NodeId")
}
- if err := initProducer(); err != nil {
- return err
+ if !producerStarted {
+ if err := initProducer(); err != nil {
+ return err
+ }
+ producerStarted = true
}
-
var topics = []string{
constvar.NsqTopicScheduleTask,
constvar.NsqTopicSendPlcAddress,
--
Gitblit v1.8.0