Merge 94ee4e8 into 564c26b

maihaoche · Jan 24, 2019 · 61e7216 · 61e7216
2 parents 564c26b + 94ee4e8
commit 61e7216
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/pom.xml b/pom.xml
@@ -33,7 +33,7 @@
 
     <groupId>com.maihaoche</groupId>
     <artifactId>spring-boot-starter-rocketmq</artifactId>
-    <version>0.1.0</version>
+    <version>0.1.1</version>
 
     <scm>
         <url>https://github.com/maihaoche/rocketmq-spring-boot-starter</url>

diff --git a/src/main/java/com/maihaoche/starter/mq/base/MessageBuilder.java b/src/main/java/com/maihaoche/starter/mq/base/MessageBuilder.java
@@ -60,7 +60,7 @@ public MessageBuilder delayTimeLevel(DelayTimeLevel delayTimeLevel) {
     }
 
     public Message build() {
-        String messageKey= "";
+        StringBuilder messageKey= new StringBuilder(StringUtils.isEmpty(key) ? "" : key);
         try {
             Field[] fields = message.getClass().getDeclaredFields();
             for (Field field : fields) {
@@ -70,7 +70,7 @@ public Message build() {
                         if(allFAnnos[i].annotationType().equals(MQKey.class)) {
                             field.setAccessible(true);
                             MQKey mqKey = MQKey.class.cast(allFAnnos[i]);
-                            messageKey = StringUtils.isEmpty(mqKey.prefix()) ? field.get(message).toString() : (mqKey.prefix() + field.get(message).toString());
+                            messageKey.append(StringUtils.SPACE).append(StringUtils.isEmpty(mqKey.prefix()) ? field.get(message).toString() : (mqKey.prefix() + ":" + field.get(message).toString()));
                         }
                     }
                 }
@@ -88,8 +88,8 @@ public Message build() {
         if (!StringUtils.isEmpty(tag)) {
             message.setTags(tag);
         }
-        if(StringUtils.isNotEmpty(messageKey)) {
-            message.setKeys(messageKey);
+        if(StringUtils.isNotEmpty(messageKey.toString())) {
+            message.setKeys(messageKey.toString());
         }
         if(delayTimeLevel != null && delayTimeLevel > 0 && delayTimeLevel <= DELAY_ARRAY.length) {
             message.setDelayTimeLevel(delayTimeLevel);