发送Heartbeat信息封装成MsgInfo

liuxiaolong

2020-12-21 6c3c6bbba02e76b8cb652516529698117a526d90

 hbusc.go

@@ -289,7 +289,16 @@
func (h *BHBus) HeartBeat(info *HeartBeatInfo) error {
   data, err := json.Marshal(*info)
   if err == nil {
      return h.send2(h.sockHB, data, h.conf.sendTimeOut)
      hbd,err := json.Marshal(MsgInfo{
         MsgType: "",
         Topic:   TOPIC_HEARTBEAT,
         Body:    data,
      })
      if err != nil {
         h.printLog("marshal heartbeat msgInfo err:", err)
         return err
      }
      return h.send2(h.sockHB, hbd, h.conf.sendTimeOut)
   }
   return err
}