(rocketmq) branch develop updated: [ISSUE #9302] SendMessageContext add message type (#9303)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 689c1ec616 [ISSUE #9302] SendMessageContext add message type (#9303)
689c1ec616 is described below

commit 689c1ec6161e9de5c3b800d28bcafa57d4e22b77
Author: ymwneu <ymw...@126.com>
AuthorDate: Wed Apr 9 15:39:24 2025 +0800

    [ISSUE #9302] SendMessageContext add message type (#9303)
---
 .../rocketmq/broker/processor/AbstractSendMessageProcessor.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
index 39befedaa2..16c137dd2e 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -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);
         }