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

[ISSUE #3949] Remove unused code in GrpcConverter

Browse Source
This commit is contained in:
zhouxiang
2022-07-13 11:29:43 +08:00
parent 31a50fe83a
commit d741618c0c
1 changed files with 0 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java
-15
View File
@@ -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;
}
}
}