File tree Expand file tree Collapse file tree 1 file changed +0
-8
lines changed
rocketmq-broker/src/processor Expand file tree Collapse file tree 1 file changed +0
-8
lines changed Original file line number Diff line number Diff line change @@ -538,13 +538,6 @@ mod tests {
538538 . as_ref( )
539539 ) ;
540540 assert_eq ! ( msg_inner. message_ext_inner. sys_flag, msg_ext. sys_flag) ;
541- /* assert_eq!(
542- msg_inner.tags_code,
543- MessageExtBrokerInner::tags_string2tags_code(
544- &TopicFilterType::SingleTag,
545- msg_ext.get_tags().as_ref().unwrap()
546- )
547- );*/
548541 assert_eq ! ( msg_inner. get_properties( ) , msg_ext. get_properties( ) ) ;
549542 assert_eq ! (
550543 msg_inner. properties_string,
@@ -555,7 +548,6 @@ mod tests {
555548 #[ test]
556549 fn end_message_transaction_with_empty_body ( ) {
557550 let mut msg_ext = MessageExt :: default ( ) ;
558- //msg_ext.set_body(None);
559551 let msg_inner = end_message_transaction ( & mut msg_ext) ;
560552 assert ! ( !msg_inner. get_body( ) . is_some_and( |b| b. is_empty( ) ) ) ;
561553 }
You can’t perform that action at this time.
0 commit comments