hbusc.go
@@ -122,12 +122,14 @@ handle.printLog("marshal registerInfo err:", err) return nil, errors.New("marshal registerInfo err:"+err.Error()) } dRegData,err := json.Marshal(MsgInfo{ s := MsgInfo{ SrcProc: ri.Proc, MsgType: MesgType_ReqRep, Topic: TOPIC_REGISTER, Body: rid, }) } handle.printLog("register MsgInfo:", s) dRegData,err := json.Marshal(s) if err != nil { handle.printLog("marshal deregister msg err:", err) return nil, err