[ISSUE #449]🎨Optimize SendMessageProcessor#process_request method (#450)

mxsm · Jun 8, 2024 · 2446b63 · 2446b63
1 parent 24ce6be
commit 2446b63
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rocketmq-broker/src/processor/send_message_processor.rs b/rocketmq-broker/src/processor/send_message_processor.rs
@@ -109,7 +109,7 @@ impl<MS: MessageStore + Send> SendMessageProcessor<MS> {
         match request_code {
             RequestCode::ConsumerSendMsgBack => self.inner.consumer_send_msg_back(&ctx, &request),
             _ => {
-                let mut request_header = parse_request_header(&request).unwrap();
+                let mut request_header = parse_request_header(&request)?;
                 let mapping_context = self
                     .topic_queue_mapping_manager
                     .build_topic_queue_mapping_context(&request_header, true);