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; - } - } }