接收设备信息改变

zhangqian

2023-09-28 f05f4cca1340f0ddec7261d4dbe65dd331224423

 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
}