diff --git a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithJsonTest.java b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithJsonTest.java index 6370f7ca8..29e0815cd 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithJsonTest.java +++ b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithJsonTest.java @@ -37,7 +37,7 @@ public class ZkNodeWithJsonTest extends BaseTest { zkServer = new TestingServer(21810); CountDownLatch latch = new CountDownLatch(1); new Thread(() -> { - String data = ResourceUtil.readUtf8Str("zookeeper/flow.el.json"); + String data = ResourceUtil.readUtf8Str("zookeeper/flow.json"); ZkClient zkClient = new ZkClient("127.0.0.1:21810"); zkClient.setZkSerializer(new ZkSerializer() { @Override @@ -58,7 +58,7 @@ public class ZkNodeWithJsonTest extends BaseTest { latch.await(); LiteflowConfig config = new LiteflowConfig(); - config.setRuleSource("json:127.0.0.1:21810"); + config.setRuleSource("el_json:127.0.0.1:21810"); flowExecutor = FlowExecutorHolder.loadInstance(config); } diff --git a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithXmlTest.java b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithXmlTest.java index 712e7fb4a..7f8e0569c 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithXmlTest.java +++ b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithXmlTest.java @@ -37,7 +37,7 @@ public class ZkNodeWithXmlTest extends BaseTest { zkServer = new TestingServer(21810); CountDownLatch latch = new CountDownLatch(1); new Thread(() -> { - String data = ResourceUtil.readUtf8Str("zookeeper/flow.el.xml"); + String data = ResourceUtil.readUtf8Str("zookeeper/flow.xml"); ZkClient zkClient = new ZkClient("127.0.0.1:21810"); zkClient.setZkSerializer(new ZkSerializer() { @Override @@ -58,7 +58,7 @@ public class ZkNodeWithXmlTest extends BaseTest { latch.await(); LiteflowConfig config = new LiteflowConfig(); - config.setRuleSource("xml:127.0.0.1:21810"); + config.setRuleSource("el_xml:127.0.0.1:21810"); flowExecutor = FlowExecutorHolder.loadInstance(config); } diff --git a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithYmlTest.java b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithYmlTest.java index b3d223de0..223c54a5a 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithYmlTest.java +++ b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithYmlTest.java @@ -37,7 +37,7 @@ public class ZkNodeWithYmlTest extends BaseTest { zkServer = new TestingServer(21810); CountDownLatch latch = new CountDownLatch(1); new Thread(() -> { - String data = ResourceUtil.readUtf8Str("zookeeper/flow.el.yml"); + String data = ResourceUtil.readUtf8Str("zookeeper/flow.yml"); ZkClient zkClient = new ZkClient("127.0.0.1:21810"); zkClient.setZkSerializer(new ZkSerializer() { @Override @@ -58,7 +58,7 @@ public class ZkNodeWithYmlTest extends BaseTest { latch.await(); LiteflowConfig config = new LiteflowConfig(); - config.setRuleSource("yml:127.0.0.1:21810"); + config.setRuleSource("el_yml:127.0.0.1:21810"); flowExecutor = FlowExecutorHolder.loadInstance(config); }