Commit aada195b authored by yanzg's avatar yanzg

不记录系统日志

parent 9cbfd1fb
......@@ -114,16 +114,13 @@ public class YzgMqProcedure implements InitializingBean {
continue;
}
// 在时间范围内,则返回大于等待时间的队列
if (timeUnit.unit >= waitTime) {
if (prevUnit == null) {
prevUnit = timeUnit;
}
if (timeUnit.unit > waitTime) {
break;
}
// 上次单位
prevUnit = timeUnit;
}
if (prevUnit.unit > waitTime || prevUnit == null) {
if (prevUnit == null) {
prevUnit = YZG_MQ_SYSTEM_QUEUE_PLAN_MIN;
} else if (prevUnit.unit < min) {
throw new CodeException("算法错误");
......
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