ソースを参照

修改如果条件不满足一直轮询

姚云青 3 年 前
コミット
15dbd81d8d

+ 6 - 0
imcs-admin-boot/imcs-business-biz/src/main/java/com/github/zuihou/business/mq/TaskWorkNode.java

@@ -408,6 +408,12 @@ public class TaskWorkNode {
                  if(bool){
                      logger.info("条件判断成功,关闭线程池");
                      pool.shutdown();
+                 }else{
+                     try {
+                         checkCon(taskNode, task, dataMap);
+                     } catch (Exception e) {
+                         e.printStackTrace();
+                     }
                  }
              }else{
                  throw new RuntimeException(ex);