opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #9302] SendMessageContext add message type (#9303)

Browse Source
This commit is contained in:
ymwneu
2025-04-09 15:39:24 +08:00
committed by GitHub
parent 17d57cac70
commit 689c1ec616
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+7
View File
@@ -380,6 +380,13 @@ public abstract class AbstractSendMessageProcessor implements NettyRequestProces
if (properties.containsKey(MessageConst.PROPERTY_SHARDING_KEY)) {
sendMessageContext.setMsgType(MessageType.Order_Msg);
} else if (properties.containsKey(MessageConst.PROPERTY_DELAY_TIME_LEVEL)
|| properties.containsKey(MessageConst.PROPERTY_TIMER_DELIVER_MS)
|| properties.containsKey(MessageConst.PROPERTY_TIMER_DELAY_SEC)
|| properties.containsKey(MessageConst.PROPERTY_TIMER_DELAY_MS)) {
sendMessageContext.setMsgType(MessageType.Delay_Msg);
} else if (Boolean.parseBoolean(properties.get(MessageConst.PROPERTY_TRANSACTION_PREPARED))) {
sendMessageContext.setMsgType(MessageType.Trans_Msg_Half);
} else {
sendMessageContext.setMsgType(MessageType.Normal_Msg);
}