Commit 5b3b2a5c authored by yanzg's avatar yanzg

修改MQ请求尸体,防止出错

parent cbdb67fa
......@@ -111,7 +111,7 @@ public class YzgMqConsumer {
TimeUnit timeUnit = YZG_MQ_SYSTEM_QUEUE_DELAY_TIME[0];
for (int i = YZG_MQ_SYSTEM_QUEUE_DELAY_TIME.length - 1; i >= 0; i--) {
timeUnit = YZG_MQ_SYSTEM_QUEUE_DELAY_TIME[i];
if (dedTime > timeUnit.unit) {
if (dedTime >= timeUnit.unit) {
break;
}
}
......
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