This is an automated email from the ASF dual-hosted git repository. zhouxzhan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 561fc2e73253ac36c055bc0f26fa7b44e1f7d052 Author: zhouxiang <[email protected]> AuthorDate: Thu Nov 17 17:55:43 2022 +0800 [ISSUE #5392] Remove unused method --- .../protocol/header/SendMessageRequestHeader.java | 74 ---------------------- 1 file changed, 74 deletions(-) diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java index be7d2038a..17ce51263 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java @@ -21,7 +21,6 @@ package org.apache.rocketmq.remoting.protocol.header; import com.google.common.base.MoreObjects; -import java.util.HashMap; import org.apache.rocketmq.remoting.annotation.CFNotNull; import org.apache.rocketmq.remoting.annotation.CFNullable; import org.apache.rocketmq.remoting.exception.RemotingCommandException; @@ -191,79 +190,6 @@ public class SendMessageRequestHeader extends TopicQueueRequestHeader { return requestHeader; } - public static SendMessageRequestHeaderV2 decodeSendMessageHeaderV2(RemotingCommand request) - throws RemotingCommandException { - SendMessageRequestHeaderV2 r = new SendMessageRequestHeaderV2(); - HashMap<String, String> fields = request.getExtFields(); - if (fields == null) { - throw new RemotingCommandException("the ext fields is null"); - } - - String s = fields.get("a"); - checkNotNull(s, "the custom field <a> is null"); - r.setA(s); - - s = fields.get("b"); - checkNotNull(s, "the custom field <b> is null"); - r.setB(s); - - s = fields.get("c"); - checkNotNull(s, "the custom field <c> is null"); - r.setC(s); - - s = fields.get("d"); - checkNotNull(s, "the custom field <d> is null"); - r.setD(Integer.parseInt(s)); - - s = fields.get("e"); - checkNotNull(s, "the custom field <e> is null"); - r.setE(Integer.parseInt(s)); - - s = fields.get("f"); - checkNotNull(s, "the custom field <f> is null"); - r.setF(Integer.parseInt(s)); - - s = fields.get("g"); - checkNotNull(s, "the custom field <g> is null"); - r.setG(Long.parseLong(s)); - - s = fields.get("h"); - checkNotNull(s, "the custom field <h> is null"); - r.setH(Integer.parseInt(s)); - - s = fields.get("i"); - if (s != null) { - r.setI(s); - } - - s = fields.get("j"); - if (s != null) { - r.setJ(Integer.parseInt(s)); - } - - s = fields.get("k"); - if (s != null) { - r.setK(Boolean.parseBoolean(s)); - } - - s = fields.get("l"); - if (s != null) { - r.setL(Integer.parseInt(s)); - } - - s = fields.get("m"); - if (s != null) { - r.setM(Boolean.parseBoolean(s)); - } - return r; - } - - private static void checkNotNull(String s, String msg) throws RemotingCommandException { - if (s == null) { - throw new RemotingCommandException(msg); - } - } - @Override public String toString() { return MoreObjects.toStringHelper(this)
