public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

enhancement #IACEH9 SQL插件中的轮询逻辑变更

Browse Source
This commit is contained in:
everywhere.z
2024-07-12 00:20:35 +08:00
parent 12b81705dc
commit eec8f9aee0
1 changed files with 1 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/JDBCHelper.java
View File

@@ -140,6 +140,7 @@ public class JDBCHelper {
pollExecutor.scheduleAtFixedRate( pollExecutor.scheduleAtFixedRate(
() -> { () -> {
try { try {
SqlReadFactory.getSqlReadPollTask(ReadType.SCRIPT).execute();
SqlReadFactory.getSqlReadPollTask(ReadType.CHAIN).execute(); SqlReadFactory.getSqlReadPollTask(ReadType.CHAIN).execute();
} catch (Exception ex) { } catch (Exception ex) {
LOG.error("poll chain fail", ex); LOG.error("poll chain fail", ex);
@@ -149,21 +150,6 @@ public class JDBCHelper {
sqlParserVO.getPollingIntervalSeconds().longValue(), sqlParserVO.getPollingIntervalSeconds().longValue(),
TimeUnit.SECONDS TimeUnit.SECONDS
); );
// 添加轮询script的定时任务
pollExecutor.scheduleAtFixedRate(
() -> {
try {
SqlReadFactory.getSqlReadPollTask(ReadType.SCRIPT).execute();
} catch (Exception ex) {
LOG.error("poll script fail", ex);
}
},
sqlParserVO.getPollingStartSeconds().longValue(),
sqlParserVO.getPollingIntervalSeconds().longValue(),
TimeUnit.SECONDS
);
} }
private void setSqlParserVO(SQLParserVO sqlParserVO) { private void setSqlParserVO(SQLParserVO sqlParserVO) {