[ISSUE #437]🔥Remove useless code (#438)

mxsm · Jun 6, 2024 · 3d56efb · 3d56efb
1 parent 62c4360
commit 3d56efb
Showing 1 changed file with 0 additions and 25 deletions.
diff --git 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<MS: MessageStore> SendMessageProcessor<MS> {
             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