|
@@ -59,8 +59,8 @@ public class MqInit implements ApplicationRunner {
|
|
|
//新增MQ公共异常
|
|
|
dynamicRabbitMq.addQueue(BizConstant.MQ_GLOBAL_EXCEPTION);
|
|
|
dynamicRabbitMq.startListener(BizConstant.MQ_GLOBAL_EXCEPTION);
|
|
|
- dynamicRabbitMq.addQueue(BizConstant.MQ_EQUIPMENT_STATUS);
|
|
|
- dynamicRabbitMq.startListener(BizConstant.MQ_EQUIPMENT_STATUS);
|
|
|
+ //dynamicRabbitMq.addQueue(BizConstant.MQ_EQUIPMENT_STATUS);
|
|
|
+ //dynamicRabbitMq.startListener(BizConstant.MQ_EQUIPMENT_STATUS);
|
|
|
|
|
|
//添加三个线边库轮询虚拟的MQ
|
|
|
// dynamicRabbitMq.addQueue(DemoLineConstant.NODE_RESOURCE_ZLZX_XBK);
|