[rocketmq] branch develop updated: Do not check nullable field in PullMessageResponseHeader (#4636)

[jinrongtong]

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

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new f4fd55b92 Do not check nullable field in PullMessageResponseHeader 
(#4636)
f4fd55b92 is described below

commit f4fd55b92164cda18aa99d108f87ef0f643270e2
Author: Zhouxiang Zhan <zhouxiang....@alibaba-inc.com>
AuthorDate: Wed Jul 20 17:48:06 2022 +0800

    Do not check nullable field in PullMessageResponseHeader (#4636)
---
 .../common/protocol/header/PullMessageResponseHeader.java         | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
 
b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
index fb92a72d6..50ffa2812 100644
--- 
a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
+++ 
b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
@@ -86,22 +86,22 @@ public class PullMessageResponseHeader implements 
CommandCustomHeader, FastCodes
             this.maxOffset = Long.parseLong(str);
         }
 
-        str = getAndCheckNotNull(fields, "offsetDelta");
+        str = fields.get("offsetDelta");
         if (str != null) {
             this.offsetDelta = Long.parseLong(str);
         }
 
-        str = getAndCheckNotNull(fields, "topicSysFlag");
+        str = fields.get("topicSysFlag");
         if (str != null) {
             this.topicSysFlag = Integer.parseInt(str);
         }
 
-        str = getAndCheckNotNull(fields, "groupSysFlag");
+        str = fields.get("groupSysFlag");
         if (str != null) {
             this.groupSysFlag = Integer.parseInt(str);
         }
 
-        str = getAndCheckNotNull(fields, "forbiddenType");
+        str = fields.get("forbiddenType");
         if (str != null) {
             this.forbiddenType = Integer.parseInt(str);
         }