Skip to content

Commit 2446b63

Browse files
[ISSUE #449]🎨Optimize SendMessageProcessor#process_request method (#450)
1 parent 24ce6be commit 2446b63

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rocketmq-broker/src/processor/send_message_processor.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ impl<MS: MessageStore + Send> SendMessageProcessor<MS> {
109109
match request_code {
110110
RequestCode::ConsumerSendMsgBack => self.inner.consumer_send_msg_back(&ctx, &request),
111111
_ => {
112-
let mut request_header = parse_request_header(&request).unwrap();
112+
let mut request_header = parse_request_header(&request)?;
113113
let mapping_context = self
114114
.topic_queue_mapping_manager
115115
.build_topic_queue_mapping_context(&request_header, true);

0 commit comments

Comments
 (0)