merge

zhangqian

2023-10-07 3e438843c57c2e3525c14832eb26e5ac343b817c

 nsq/nsq.go

@@ -57,5 +57,12 @@
      }
   })

   safe.Go(func() {
      err := Consume(fmt.Sprintf(constvar.NsqTopicDeviceUpdate, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
      if err != nil {
         logx.Errorf("start nsq consume err: %v", err)
      }
   })

   return nil
}