We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ecd2856 commit 2e6ef07Copy full SHA for 2e6ef07
1 file changed
rocketmq-broker/src/processor/send_message_processor.rs
@@ -140,7 +140,7 @@ where
140
|ctx: &mut SendMessageContext, cmd: &mut RemotingCommand| {
141
inner.execute_send_message_hook_after(Some(cmd), ctx)
142
};
143
- if request_header.batch.is_none() || !request_header.batch.unwrap() {
+ if !request_header.batch.unwrap_or(false) {
144
//handle single message
145
Ok(self
146
.send_message(
0 commit comments