Commit da35e490 authored by yanzg's avatar yanzg

不记录系统日志

parent 130d43ea
...@@ -83,7 +83,7 @@ public class YzgMqProcedure implements InitializingBean { ...@@ -83,7 +83,7 @@ public class YzgMqProcedure implements InitializingBean {
} }
for (TimeUnit item : YZG_MQ_SYSTEM_QUEUE_PLAN_TIME) { for (TimeUnit item : YZG_MQ_SYSTEM_QUEUE_PLAN_TIME) {
// 在时间范围内,则返回大于等待时间的队列 // 在时间范围内,则返回大于等待时间的队列
if (item.unit < min) { if (item.unit < min && item != YZG_MQ_SYSTEM_QUEUE_PLAN_MIN) {
continue; continue;
} }
mqService.createQueue(new QueueVo(getQueueName(item), item.unit, YZG_MQ_SYSTEM_QUEUE_PLAN)); mqService.createQueue(new QueueVo(getQueueName(item), item.unit, YZG_MQ_SYSTEM_QUEUE_PLAN));
......
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