关闭nsq时也关闭生产者

zhangqian

2023-10-21 15f1cdb2c358d1c120b5ab4bc28ef596e3d93b80

 nsq/msg_handler.go

@@ -305,7 +305,12 @@
      record.Method != oldPlcRecord.Method ||
      record.Address != oldPlcRecord.Address ||
      record.Detail != oldPlcRecord.Detail {
      err = model.NewDevicePlcSearch().SetDeviceId(msg.ID).Save(&record)

      oldPlcRecord.Port = record.Port
      oldPlcRecord.Method = record.Method
      oldPlcRecord.Address = record.Address
      oldPlcRecord.Detail = record.Detail
      err = model.NewDevicePlcSearch().Save(oldPlcRecord)
   }
   if err != nil {
      return err