commit c1e8b30151df6c420ed3e272682d9d8d35d8512a
author wangxing <wangxing@richinfo.cn> Thu May 30 16:24:54 2019 +0800
committer wangxing <wangxing@richinfo.cn> Thu May 30 16:24:54 2019 +0800
tree 09ae04d5f52e9947023904dc48acaf391cffaee0
parent 5cfba3cf6d7a9b16f08f67f4d42b148623e9bebc

optimization

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java

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 7cd500e..06ea118 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
@@ -106,7 +106,7 @@
             properties.forEach((key, val) -> {
                 if (!MessageConst.STRING_HASH_SET.contains(key) && !MessageHeaders.ID.equals(key)
                         && !MessageHeaders.TIMESTAMP.equals(key) &&
-                        !MessageConst.STRING_HASH_SET.contains(key.replaceFirst("^" + RocketMQHeaders.PREFIX, ""))) {
+                        (!key.startsWith(RocketMQHeaders.PREFIX) || !MessageConst.STRING_HASH_SET.contains(key.replaceFirst("^" + RocketMQHeaders.PREFIX, "")))) {
                     messageBuilder.setHeader(key, val);
                 }
             });