日志

zhangqian

2023-10-20 72c513ce21caa54369dda02f2b58c006d2ca90c5

日志

 nsq/nsq.go

@@ -53,6 +53,7 @@
            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)