Commit aa040dfa authored by yanzg's avatar yanzg

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

parent 5b3b2a5c
...@@ -125,6 +125,7 @@ public class YzgMqConsumer { ...@@ -125,6 +125,7 @@ public class YzgMqConsumer {
QueueVo queueVo = new QueueVo(mqName, count * timeUnit.unit, YzgMqConsumer.YZG_MQ_SYSTEM_QUEUE); QueueVo queueVo = new QueueVo(mqName, count * timeUnit.unit, YzgMqConsumer.YZG_MQ_SYSTEM_QUEUE);
queueVo.check(); queueVo.check();
mqService.createQueue(queueVo); mqService.createQueue(queueVo);
cacheQueueName.put(mqName, true);
} }
} }
} }
......
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