From d741618c0c7e44cd77665dbcc19238d3ec470d4d Mon Sep 17 00:00:00 2001 From: zhouxiang Date: Wed, 25 May 2022 19:21:49 +0800 Subject: [PATCH] [ISSUE #3949] Remove unused code in GrpcConverter --- .../proxy/grpc/v2/common/GrpcConverter.java | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java index 04169146b0..72db47eccf 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java @@ -35,7 +35,6 @@ import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; import org.apache.commons.lang3.StringUtils; -import org.apache.rocketmq.common.attribute.TopicMessageType; import org.apache.rocketmq.common.constant.LoggerName; import org.apache.rocketmq.common.consumer.ReceiptHandle; import org.apache.rocketmq.common.filter.ExpressionType; @@ -230,18 +229,4 @@ public class GrpcConverter { .setName(NamespaceUtil.withoutNamespace(resourceNameWithNamespace)) .build(); } - - public static TopicMessageType buildTopicMessageType(MessageType messageType) { - if (messageType.equals(MessageType.NORMAL)) { - return TopicMessageType.NORMAL; - } else if (messageType.equals(MessageType.FIFO)) { - return TopicMessageType.FIFO; - } else if (messageType.equals(MessageType.DELAY)) { - return TopicMessageType.DELAY; - } else if (messageType.equals(MessageType.TRANSACTION)) { - return TopicMessageType.TRANSACTION; - } else { - return TopicMessageType.UNSPECIFIED; - } - } }