@@ -28,6 +28,7 @@ func (r *MQNtfReq) GetProtoBytes() (bytes *[]byte, err error) {
return
}
if m.Header != nil {
+ m.Header.RequestID = new(uint32)
*m.Header.RequestID = 0
} else {
err = errors.New("请求信息序列化失败")