MQ顺序消费

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/service/RuleEngineExService.java

@@ -80,6 +80,7 @@ public class RuleEngineExService extends RuleEngineServiceImpl {
     private DstDataSourceExService dstDataSourceService;
 
     @Autowired
+    @Lazy
     DefaultMQProducer defaultMQProducer;
 
     @Autowired

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/util/MQConsumeMsgListenerProcessor.java

@@ -60,9 +60,9 @@ public class MQConsumeMsgListenerProcessor implements MessageListenerOrderly {
         try {
         String body = new String(messageExt.getBody(), "utf-8");
 
-        Thread.sleep(10000);
-//        EngineMQMsg engineMQMsg = JSON.parseObject(body, new TypeReference<EngineMQMsg>() {});
-//        ruleEngineExService.processData(engineMQMsg);
+//        Thread.sleep(10000);
+        EngineMQMsg engineMQMsg = JSON.parseObject(body, new TypeReference<EngineMQMsg>() {});
+        ruleEngineExService.processData(engineMQMsg);
         } catch (Exception e) {
             log.error("获取MQ消息内容异常{}",e);
         }