KingChan
/
liteFlow
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

完善 liteflow-testcase-el-nospring 测试用例

This commit is contained in:
tangkc 2022-07-10 20:47:29 +08:00
parent 46a05cfb79
commit b1301f4e91
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithJsonTest.java
View File

@ -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);
}

4
liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithXmlTest.java
View File

@ -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);
}

4
liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/zookeeper/ZkNodeWithYmlTest.java
View File

@ -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);
}