File tree 1 file changed +0
-25
lines changed
rocketmq-broker/src/processor
1 file changed +0
-25
lines changed Original file line number Diff line number Diff line change @@ -26,7 +26,6 @@ use rocketmq_common::{
26
26
message_single:: { MessageExt , MessageExtBrokerInner } ,
27
27
MessageConst ,
28
28
} ,
29
- mix_all:: RETRY_GROUP_TOPIC_PREFIX ,
30
29
topic:: TopicValidator ,
31
30
} ,
32
31
utils:: { message_utils, util_all} ,
@@ -215,30 +214,6 @@ impl<MS: MessageStore> SendMessageProcessor<MS> {
215
214
return Some ( response) ;
216
215
}
217
216
218
- if request_header. topic . len ( ) > i8:: MAX as usize {
219
- return Some (
220
- response
221
- . set_code ( ResponseCode :: MessageIllegal )
222
- . set_remark ( Some ( format ! (
223
- "message topic length too long {}" ,
224
- request_header. topic( ) . len( )
225
- ) ) ) ,
226
- ) ;
227
- }
228
-
229
- if !request_header. topic . is_empty ( )
230
- && request_header. topic . starts_with ( RETRY_GROUP_TOPIC_PREFIX )
231
- {
232
- return Some (
233
- response
234
- . set_code ( ResponseCode :: MessageIllegal )
235
- . set_remark ( Some ( format ! (
236
- "batch request does not support retry group {}" ,
237
- request_header. topic( )
238
- ) ) ) ,
239
- ) ;
240
- }
241
-
242
217
let mut topic_config = self
243
218
. inner
244
219
. topic_config_manager
You can’t perform that action at this time.
0 commit comments