From ce2a9c854e205904081c6ef1275a11e240e970f3 Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Wed, 29 May 2024 21:19:58 +0800 Subject: [PATCH] =?UTF-8?q?feature=20#I9PVQ7=20=E5=86=B3=E7=AD=96=E8=B7=AF?= =?UTF-8?q?=E7=94=B1=E4=B8=AD=E5=A2=9E=E5=8A=A0namespace=EF=BC=8C=E5=8F=AF?= =?UTF-8?q?=E4=BB=A5=E6=89=A7=E8=A1=8C=E6=8C=87=E5=AE=9A=E5=91=BD=E5=90=8D?= =?UTF-8?q?=E7=A9=BA=E9=97=B4=E7=9A=84=E5=86=B3=E7=AD=96=E8=B7=AF=E7=94=B1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../yomahub/liteflow/parser/sql/read/SqlReadFactory.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/SqlReadFactory.java b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/SqlReadFactory.java index f22f3657..a49b33d3 100644 --- a/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/SqlReadFactory.java +++ b/liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/read/SqlReadFactory.java @@ -23,16 +23,16 @@ public class SqlReadFactory { private static final Map> POLL_TASK_MAP = new HashMap<>(); public static void registerRead(SQLParserVO config) { - READ_MAP.putIfAbsent(ReadType.CHAIN, new ChainRead(config)); - READ_MAP.putIfAbsent(ReadType.SCRIPT, new ScriptRead(config)); + READ_MAP.put(ReadType.CHAIN, new ChainRead(config)); + READ_MAP.put(ReadType.SCRIPT, new ScriptRead(config)); } public static void registerSqlReadPollTask(ReadType readType) { SqlRead sqlRead = getSqlRead(readType); if (ReadType.CHAIN.equals(readType)) { - POLL_TASK_MAP.putIfAbsent(ReadType.CHAIN, new ChainReadPollTask((ChainRead)sqlRead)); + POLL_TASK_MAP.put(ReadType.CHAIN, new ChainReadPollTask((ChainRead)sqlRead)); } else if (ReadType.SCRIPT.equals(readType)) { - POLL_TASK_MAP.putIfAbsent(ReadType.SCRIPT, new ScriptReadPollTask((ScriptRead)sqlRead)); + POLL_TASK_MAP.put(ReadType.SCRIPT, new ScriptReadPollTask((ScriptRead)sqlRead)); } }