mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-31 02:20:15 +08:00
This commit is contained in:
@@ -139,7 +139,10 @@ public class GrpcConverter {
|
||||
}
|
||||
|
||||
// message_id
|
||||
String uniqKey = messageExt.getMsgId();
|
||||
String uniqKey = messageExt.getProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX);
|
||||
if (uniqKey == null) {
|
||||
uniqKey = messageExt.getMsgId();
|
||||
}
|
||||
if (uniqKey != null) {
|
||||
systemPropertiesBuilder.setMessageId(uniqKey);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user