You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/06/14 07:22:23 UTC
[rocketmq] branch 5.0.0-beta updated: Change PullMessageRequestHeader maxMsgNums to CFNullable
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 <zh...@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 {
}