[rocketmq-spring] branch master updated: [ISSUE #411] Support DELAY and WAIT properties in RocketMQHeaders.java, which can convert Spring-Message to Rocket-Message conveniently #

[jinrongtong]

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

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new ba0bc52  [ISSUE #411] Support DELAY and WAIT properties in 
RocketMQHeaders.java, which can convert Spring-Message to Rocket-Message 
conveniently #
ba0bc52 is described below

commit ba0bc52673f90eb17dc41c815f90c2c729f74942
Author: Jiangnan Jia <jiajiangnan...@foxmail.com>
AuthorDate: Mon Feb 7 17:14:06 2022 +0800

    [ISSUE #411] Support DELAY and WAIT properties in RocketMQHeaders.java, 
which can convert Spring-Message to Rocket-Message conveniently #
---
 .../main/java/org/apache/rocketmq/spring/support/RocketMQHeaders.java | 2 ++
 .../main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java    | 4 +++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQHeaders.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQHeaders.java
index 7afefbd..8c49809 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQHeaders.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQHeaders.java
@@ -31,4 +31,6 @@ public class RocketMQHeaders {
     public static final String QUEUE_ID = "QUEUE_ID";
     public static final String SYS_FLAG = "SYS_FLAG";
     public static final String TRANSACTION_ID = "TRANSACTION_ID";
+    public static final String DELAY = "DELAY";
+    public static final String WAIT = "WAIT";
 }
diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
index a5b3b1b..e598363 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
@@ -105,7 +105,9 @@ public class RocketMQUtil {
                 setHeader(toRocketHeaderKey(RocketMQHeaders.FLAG), 
message.getFlag()).
                 setHeader(toRocketHeaderKey(RocketMQHeaders.QUEUE_ID), 
message.getQueueId()).
                 setHeader(toRocketHeaderKey(RocketMQHeaders.SYS_FLAG), 
message.getSysFlag()).
-                setHeader(toRocketHeaderKey(RocketMQHeaders.TRANSACTION_ID), 
message.getTransactionId());
+                setHeader(toRocketHeaderKey(RocketMQHeaders.TRANSACTION_ID), 
message.getTransactionId()).
+                setHeader(toRocketHeaderKey(RocketMQHeaders.DELAY), 
message.getDelayTimeLevel()).
+                setHeader(toRocketHeaderKey(RocketMQHeaders.WAIT), 
message.isWaitStoreMsgOK());
         addUserProperties(message.getProperties(), messageBuilder);
         return messageBuilder.build();
     }