[rocketmq] branch 5.0.0-beta updated: Change PullMessageRequestHeader maxMsgNums to CFNullable

[yukon]

This is an automated email from the ASF dual-hosted git repository.

yukon pushed a commit to branch 5.0.0-beta
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-beta by this push:
     new 33fd33089 Change PullMessageRequestHeader maxMsgNums to CFNullable
33fd33089 is described below

commit 33fd330899145654b7c25eac36c0ceb3bbfe5aba
Author: zhouxiang <zhouxiang....@alibaba-inc.com>
AuthorDate: Tue Jun 14 14:47:29 2022 +0800

    Change PullMessageRequestHeader maxMsgNums to CFNullable
---
 .../rocketmq/common/protocol/header/PullMessageRequestHeader.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
 
b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
index 5ac1899d5..08790fc29 100644
--- 
a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
+++ 
b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
@@ -35,8 +35,6 @@ public class PullMessageRequestHeader extends 
TopicQueueRequestHeader {
     @CFNotNull
     private Long queueOffset;
     @CFNotNull
-    private Integer maxMsgBytes;
-    @CFNotNull
     private Integer maxMsgNums;
     @CFNotNull
     private Integer sysFlag;
@@ -50,6 +48,9 @@ public class PullMessageRequestHeader extends 
TopicQueueRequestHeader {
     private Long subVersion;
     private String expressionType;
 
+    @CFNullable
+    private Integer maxMsgBytes;
+
     @Override
     public void checkFields() throws RemotingCommandException {
     }