opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Change PullMessageRequestHeader maxMsgNums to CFNullable

Browse Source
This commit is contained in:
zhouxiang
2022-06-14 15:22:05 +08:00
committed by yukon
parent 42e5d734ee
commit 33fd330899
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
+3 -2
View File
@@ -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 {
}