Commit c5de36aa authored by yanzg's avatar yanzg

修改公式和计算帮助类

parent 3b68d2b3
...@@ -121,9 +121,9 @@ public class YzgMqProcedure implements InitializingBean { ...@@ -121,9 +121,9 @@ public class YzgMqProcedure implements InitializingBean {
MessageVo message = req.getMessage(); MessageVo message = req.getMessage();
if (waitTime > 0) { if (waitTime > 0) {
TimeUnit timeUnit = getTimeUnit(waitTime); TimeUnit timeUnit = getTimeUnit(waitTime);
long dedTime = Math.min(timeUnit.unit, waitTime);
String queueName = getQueueName(timeUnit);
String json = JsonHelper.serialize(req); String json = JsonHelper.serialize(req);
String queueName = getQueueName(timeUnit);
long dedTime = Math.min(timeUnit.unit, waitTime);
message = new MessageVo(queueName, json, dedTime); message = new MessageVo(queueName, json, dedTime);
} else { } else {
message.setDedTime(0); message.setDedTime(0);
......
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