From 9a2c872821aadd4eeb7cdb8ec34a75b6d297055c Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期三, 18 十月 2023 14:35:03 +0800
Subject: [PATCH] fix
---
nsq/nsq.go | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/nsq/nsq.go b/nsq/nsq.go
index 4fb71b6..888cf08 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -4,8 +4,8 @@
"apsClient/conf"
"apsClient/constvar"
"apsClient/pkg/logx"
+ "apsClient/pkg/nsqclient"
"apsClient/pkg/safe"
- "basic.com/aps/nsqclient.git"
"context"
"errors"
"fmt"
@@ -47,12 +47,12 @@
}
func (c *consumerManager) AddConsumer(topic string) {
- client, err := NewConsumer(topic, conf.Conf.System.DeviceId)
- if err != nil {
- logx.Errorf("start nsq consume err: %v", err)
- }
- c.clients.Store(topic, client)
safe.Go(func() {
+ client, err := NewConsumer(topic, conf.Conf.System.DeviceId)
+ if err != nil {
+ logx.Errorf("start nsq consume err: %v", err)
+ }
+ c.clients.Store(topic, client)
if len(conf.Conf.NsqConf.NsqlookupdAddr) > 0 {
if err = client.RunLookupd(conf.Conf.NsqConf.NsqlookupdAddr, 1); err != nil {
logx.Errorf("RunLookupd err:%v", err)
@@ -64,8 +64,8 @@
return
}
}
+ logx.Infof("add consumer success, topic:%v", topic)
})
- logx.Infof("add consumer success, topic:%v", topic)
}
func (c *consumerManager) stop() {
--
Gitblit v1.8.0