Merge branch 'ver1.1' of http://192.168.0.204/yzg/yzg-util

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/YzgMqProcedure.java

@@ -213,14 +213,16 @@ public class YzgMqProcedure implements InitializingBean {
             } else if (dedTimeType == MessageVo.DED_TIME_TYPE_PRIVATE) {
                 Set<Long> longs = privateQueue.computeIfAbsent(key, k -> new HashSet<>());
                 long dedTime = message.getDedTime();
+                String queueName = String.format("%s:%d", key, dedTime);
                 if (!longs.contains(dedTime)) {
                     synchronized (longs) {
-                        String queueName = String.format("%s:%d", key, dedTime);
                         queueService.create(new QueueVo(queueName, dedTime, message.getRouteKey()));
                         longs.add(dedTime);
                     }
                 }
-
+                message.setExchangeName(queueName);
+                message.setRouteKey(queueName);
+                message.setDedTime(0);
             } else {
                 throw new RuntimeException("不支持的延迟处理类型");
             }