From 3bbca727aec8d59e34b6830a7be9bba9ed6b6b2e Mon Sep 17 00:00:00 2001 From: zhouxiang Date: Fri, 27 May 2022 11:27:02 +0800 Subject: [PATCH] [ISSUE #3949] Remove unused method --- .../proxy/grpc/v2/producer/SendMessageActivity.java | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java index d12d51953a..998c0276fb 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java @@ -241,18 +241,6 @@ public class SendMessageActivity extends AbstractMessingActivity { return builder.build(); } - protected MessageType parseMessageType(List messageList) { - MessageType messageType = messageList.get(0).getSystemProperties().getMessageType(); - for (Message message : messageList) { - MessageType messageType0 = message.getSystemProperties().getMessageType(); - if (messageType0 != messageType) { - throw new GrpcProxyException(Code.ILLEGAL_MESSAGE, "message type is not match"); - } - messageType = messageType0; - } - return messageType; - } - protected static class SendMessageQueueSelector implements QueueSelector { private final SendMessageRequest request;