Skip to content

Commit a32d712

Browse files
committed
[ISSUE #1214]🔥Optimize Send message put PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX Property
1 parent 7157b59 commit a32d712

File tree

1 file changed

+16
-8
lines changed

1 file changed

+16
-8
lines changed

‎rocketmq-broker/src/processor/send_message_processor.rs

+16-8
Original file line numberDiff line numberDiff line change
@@ -462,14 +462,22 @@ where
462462
message_ext.message_ext_inner.message.flag = request_header.flag;
463463

464464
let uniq_key = ori_props.get(MessageConst::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX);
465-
let uniq_key_inner = match uniq_key {
466-
Some(inner) if !inner.is_empty() => inner.clone(),
467-
_ => CheetahString::from_string(MessageClientIDSetter::create_uniq_id()),
468-
};
469-
ori_props.insert(
470-
CheetahString::from_static_str(MessageConst::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX),
471-
uniq_key_inner,
472-
);
465+
if !uniq_key.is_some_and(|uniq_key_inner| uniq_key_inner.is_empty()) {
466+
ori_props.insert(
467+
CheetahString::from_static_str(
468+
MessageConst::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX,
469+
),
470+
CheetahString::from_string(MessageClientIDSetter::create_uniq_id()),
471+
);
472+
}
473+
// let uniq_key_inner = match uniq_key {
474+
// Some(inner) if !inner.is_empty() => inner.clone(),
475+
// _ => CheetahString::from_string(MessageClientIDSetter::create_uniq_id()),
476+
// };
477+
// ori_props.insert(
478+
// CheetahString::from_static_str(MessageConst::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX),
479+
// uniq_key_inner,
480+
// );
473481

474482
let tra_flag = ori_props
475483
.get(MessageConst::PROPERTY_TRANSACTION_PREPARED)

0 commit comments

Comments
 (0)