日志

zhangqian

2023-10-20 6bfbe5092d05cd75a8f8772ad715871f7639a42e

日志

 nsq/nsq.go

@@ -53,7 +53,7 @@
            logx.Errorf("start nsq consume err: %v", err)
        }
        c.clients.Store(topic, client)

        logx.Infof("add consumer success, topic:%v", topic)
        if len(conf.Conf.NsqConf.NsqlookupdAddr) > 0 {
            if err = client.RunLookupd(conf.Conf.NsqConf.NsqlookupdAddr, 1); err != nil {
                logx.Errorf("RunLookupd err:%v", err)
@@ -65,7 +65,6 @@
                return
            }
        }
        logx.Infof("add consumer success, topic:%v", topic)
    })
}