Skip to content

Commit 2e6ef07

Browse files
authored
[ISSUE #1525]Optimization condition judgment
1 parent ecd2856 commit 2e6ef07

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rocketmq-broker/src/processor/send_message_processor.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ where
140140
|ctx: &mut SendMessageContext, cmd: &mut RemotingCommand| {
141141
inner.execute_send_message_hook_after(Some(cmd), ctx)
142142
};
143-
if request_header.batch.is_none() || !request_header.batch.unwrap() {
143+
if !request_header.batch.unwrap_or(false) {
144144
//handle single message
145145
Ok(self
146146
.send_message(

0 commit comments

Comments
 (0)