Skip to content

Y
yzg-util
Commit d000e9db authored by yanzg's avatar yanzg
Browse files
Options

修改公式和计算帮助类

parent 4d8f7eb1
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/YzgMqProcedure.java
View file @ d000e9db
...@@ -59,8 +59,8 @@ public class YzgMqProcedure implements InitializingBean { ...@@ -59,8 +59,8 @@ public class YzgMqProcedure implements InitializingBean {
public void afterPropertiesSet() throws Exception { public void afterPropertiesSet() throws Exception {
mqService.createQueue(new QueueVo(YZG_MQ_SYSTEM_QUEUE)); mqService.createQueue(new QueueVo(YZG_MQ_SYSTEM_QUEUE));
mqService.createQueue(new QueueVo(YZG_MQ_SYSTEM_QUEUE_PLAN)); mqService.createQueue(new QueueVo(YZG_MQ_SYSTEM_QUEUE_PLAN));
YZG_MQ_SYSTEM_QUEUE_PLAN_TIME.add(YZG_MQ_SYSTEM_QUEUE_PLAN_MIN);
if (YZG_MQ_SYSTEM_QUEUE_PLAN_TIME.isEmpty()) { if (YZG_MQ_SYSTEM_QUEUE_PLAN_TIME.isEmpty()) {
YZG_MQ_SYSTEM_QUEUE_PLAN_TIME.add(YZG_MQ_SYSTEM_QUEUE_PLAN_MIN);
long now = YZG_MQ_SYSTEM_QUEUE_PLAN_MIN.unit; long now = YZG_MQ_SYSTEM_QUEUE_PLAN_MIN.unit;
int count = 1; int count = 1;
while (now < YZG_MQ_SYSTEM_QUEUE_PLAN_MAX.unit) { while (now < YZG_MQ_SYSTEM_QUEUE_PLAN_MAX.unit) {
......
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