日志

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)
   })
}