From 8e6b549ed9fbe792c1cd48fcd6be11035d5834a7 Mon Sep 17 00:00:00 2001 From: shadowsoy Date: Thu, 6 Jun 2024 13:25:21 +0000 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#437]=F0=9F=94=A5Remove=20useless=20co?= =?UTF-8?q?de?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/processor/send_message_processor.rs | 25 ------------------- 1 file changed, 25 deletions(-) diff --git a/rocketmq-broker/src/processor/send_message_processor.rs b/rocketmq-broker/src/processor/send_message_processor.rs index c2682ac9..ca093ab7 100644 --- a/rocketmq-broker/src/processor/send_message_processor.rs +++ b/rocketmq-broker/src/processor/send_message_processor.rs @@ -26,7 +26,6 @@ use rocketmq_common::{ message_single::{MessageExt, MessageExtBrokerInner}, MessageConst, }, - mix_all::RETRY_GROUP_TOPIC_PREFIX, topic::TopicValidator, }, utils::{message_utils, util_all}, @@ -215,30 +214,6 @@ impl SendMessageProcessor { return Some(response); } - if request_header.topic.len() > i8::MAX as usize { - return Some( - response - .set_code(ResponseCode::MessageIllegal) - .set_remark(Some(format!( - "message topic length too long {}", - request_header.topic().len() - ))), - ); - } - - if !request_header.topic.is_empty() - && request_header.topic.starts_with(RETRY_GROUP_TOPIC_PREFIX) - { - return Some( - response - .set_code(ResponseCode::MessageIllegal) - .set_remark(Some(format!( - "batch request does not support retry group {}", - request_header.topic() - ))), - ); - } - let mut topic_config = self .inner .topic_config_manager