Commit 130d43ea authored by yanzg's avatar yanzg

不记录系统日志

parent f8bd3c32
......@@ -110,9 +110,13 @@ public class YzgMqProcedure implements InitializingBean {
TimeUnit prevUnit = YZG_MQ_SYSTEM_QUEUE_PLAN_MIN;
for (TimeUnit timeUnit : YZG_MQ_SYSTEM_QUEUE_PLAN_TIME) {
// 在时间范围内,则返回大于等待时间的队列
if (timeUnit.unit >= waitTime && timeUnit.unit > min) {
if (timeUnit.unit >= waitTime) {
break;
}
// 判断时间
if (timeUnit.unit < min) {
continue;
}
// 上次单位
prevUnit = timeUnit;
}
......
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