Commit dfd6fdbe authored by yanzg's avatar yanzg

1.0-SNAPSHOT的支持

parent cddf327f
...@@ -204,13 +204,13 @@ public class YzgMqProcedure implements InitializingBean { ...@@ -204,13 +204,13 @@ public class YzgMqProcedure implements InitializingBean {
if (waitTime > 0) { if (waitTime > 0) {
TimeUnit timeUnit = getTimeUnit(waitTime); TimeUnit timeUnit = getTimeUnit(waitTime);
int dedTimeType = message.getDedTimeType(); int dedTimeType = message.getDedTimeType();
String key = StringHelper.getId(message.getExchangeName(), message.getRouteKey());
if (dedTimeType == MessageVo.DED_TIME_TYPE_PUBLIC) { if (dedTimeType == MessageVo.DED_TIME_TYPE_PUBLIC) {
String json = JsonHelper.serialize(req); String json = JsonHelper.serialize(req);
String queueName = getQueueName(timeUnit); String queueName = getQueueName(timeUnit);
long dedTime = Math.min(timeUnit.unit, waitTime); long dedTime = Math.min(timeUnit.unit, waitTime);
message = new MessageVo(queueName, json, dedTime); message = new MessageVo(queueName, json, dedTime);
} else if (dedTimeType == MessageVo.DED_TIME_TYPE_PRIVATE) { } else if (dedTimeType == MessageVo.DED_TIME_TYPE_PRIVATE) {
String key = StringHelper.getId(message.getRouteKey());
Set<Long> longs = privateQueue.computeIfAbsent(key, k -> new HashSet<>()); Set<Long> longs = privateQueue.computeIfAbsent(key, k -> new HashSet<>());
long dedTime = message.getDedTime(); long dedTime = message.getDedTime();
String queueName = String.format("%s:%d", key, dedTime); String queueName = String.format("%s:%d", key, dedTime);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment