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

ELBus中的commonNode方法改成element

Browse Source
This commit is contained in:
everywhere.z
2025-02-22 00:54:46 +08:00
parent ef6f53bd08
commit 236538079f
5 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
liteflow-el-builder/src/main/java/com/yomahub/liteflow/builder/el/ELBus.java
View File

@@ -126,7 +126,7 @@ public class ELBus {
* @param nodeId 节点id * @param nodeId 节点id
* @return {@link CommonNodeELWrapper} * @return {@link CommonNodeELWrapper}
*/ */
public static CommonNodeELWrapper commonNode(String nodeId){ public static CommonNodeELWrapper element(String nodeId){
return new CommonNodeELWrapper(nodeId); return new CommonNodeELWrapper(nodeId);
} }

4
liteflow-testcase-el/liteflow-testcase-el-builder/src/test/java/com/yomahub/liteflow/test/builder/MaxWaitSecondBuilderTest.java
View File

@@ -14,8 +14,8 @@ public class MaxWaitSecondBuilderTest extends BaseTest {
// node层面 // node层面
@Test @Test
public void testMaxWaitSecond1(){ public void testMaxWaitSecond1(){
CommonNodeELWrapper nodeA = ELBus.commonNode("a").maxWaitSeconds(4); CommonNodeELWrapper nodeA = ELBus.element("a").maxWaitSeconds(4);
CommonNodeELWrapper nodeB = ELBus.commonNode("b").maxWaitSeconds(4); CommonNodeELWrapper nodeB = ELBus.element("b").maxWaitSeconds(4);
WhenELWrapper whenELWrapper = ELBus.when(nodeA, nodeB); WhenELWrapper whenELWrapper = ELBus.when(nodeA, nodeB);
Assertions.assertEquals("WHEN(a.maxWaitSeconds(4),b.maxWaitSeconds(4));", whenELWrapper.toEL()); Assertions.assertEquals("WHEN(a.maxWaitSeconds(4),b.maxWaitSeconds(4));", whenELWrapper.toEL());
} }

8
liteflow-testcase-el/liteflow-testcase-el-builder/src/test/java/com/yomahub/liteflow/test/builder/RetryBuilderTest.java
View File

@@ -16,8 +16,8 @@ public class RetryBuilderTest extends BaseTest {
// node上进行retry // node上进行retry
@Test @Test
public void testRetry1(){ public void testRetry1(){
CommonNodeELWrapper nodeA = ELBus.commonNode("a").retry(2); CommonNodeELWrapper nodeA = ELBus.element("a").retry(2);
CommonNodeELWrapper nodeB = ELBus.commonNode("b").retry(3); CommonNodeELWrapper nodeB = ELBus.element("b").retry(3);
WhenELWrapper whenELWrapper = ELBus.when(nodeA, nodeB); WhenELWrapper whenELWrapper = ELBus.when(nodeA, nodeB);
Assertions.assertEquals("WHEN(a.retry(2),b.retry(3));", whenELWrapper.toEL()); Assertions.assertEquals("WHEN(a.retry(2),b.retry(3));", whenELWrapper.toEL());
} }
@@ -25,8 +25,8 @@ public class RetryBuilderTest extends BaseTest {
// node上进行retry，带exception // node上进行retry，带exception
@Test @Test
public void testRetry2(){ public void testRetry2(){
CommonNodeELWrapper nodeA = ELBus.commonNode("a").retry(2, "java.lang.NullPointerException"); CommonNodeELWrapper nodeA = ELBus.element("a").retry(2, "java.lang.NullPointerException");
CommonNodeELWrapper nodeB = ELBus.commonNode("b").retry(3, "java.lang.NullPointerException", "java.lang.ArrayIndexOutOfBoundsException"); CommonNodeELWrapper nodeB = ELBus.element("b").retry(3, "java.lang.NullPointerException", "java.lang.ArrayIndexOutOfBoundsException");
WhenELWrapper whenELWrapper = ELBus.when(nodeA, nodeB); WhenELWrapper whenELWrapper = ELBus.when(nodeA, nodeB);
Assertions.assertEquals("WHEN(a.retry(2,\"java.lang.NullPointerException\"),b.retry(3,\"java.lang.NullPointerException\",\"java.lang.ArrayIndexOutOfBoundsException\"));", Assertions.assertEquals("WHEN(a.retry(2,\"java.lang.NullPointerException\"),b.retry(3,\"java.lang.NullPointerException\",\"java.lang.ArrayIndexOutOfBoundsException\"));",
whenELWrapper.toEL()); whenELWrapper.toEL());

2
liteflow-testcase-el/liteflow-testcase-el-builder/src/test/java/com/yomahub/liteflow/test/builder/ThenELBuilderTest.java
View File

@@ -28,7 +28,7 @@ public class ThenELBuilderTest extends BaseTest {
name2Value.put("name", "zhangsan"); name2Value.put("name", "zhangsan");
name2Value.put("age", 18); name2Value.put("age", 18);
String expected = "nodeData = '{\"name\":\"zhangsan\",\"age\":18}';\nTHEN(\n\ta.tag(\"tagA\").data(nodeData).maxWaitSeconds(10).retry(2),\n\tnode(\"b\")\n);"; String expected = "nodeData = '{\"name\":\"zhangsan\",\"age\":18}';\nTHEN(\n\ta.tag(\"tagA\").data(nodeData).maxWaitSeconds(10).retry(2),\n\tnode(\"b\")\n);";
String actualEl = ELBus.then(ELBus.commonNode("a").data("nodeData", name2Value).tag("tagA").maxWaitSeconds(10).retry(2), ELBus.node("b")).toEL(true); String actualEl = ELBus.then(ELBus.element("a").data("nodeData", name2Value).tag("tagA").maxWaitSeconds(10).retry(2), ELBus.node("b")).toEL(true);
System.out.println(actualEl); System.out.println(actualEl);
Assertions.assertEquals(expected, actualEl); Assertions.assertEquals(expected, actualEl);
} }

2
liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigTest1.java
View File

@@ -42,7 +42,7 @@ public class LiteflowConfigTest1 extends BaseTest {
Assertions.assertEquals(300000L, config.getDelay().longValue()); Assertions.assertEquals(300000L, config.getDelay().longValue());
Assertions.assertEquals(300000L, config.getPeriod().longValue()); Assertions.assertEquals(300000L, config.getPeriod().longValue());
Assertions.assertFalse(config.getEnableLog()); Assertions.assertFalse(config.getEnableLog());
Assertions.assertEquals(16, config.getGlobalThreadPoolSize().longValue()); Assertions.assertEquals(64, config.getGlobalThreadPoolSize().longValue());
Assertions.assertEquals(512, config.getGlobalThreadPoolQueueSize().longValue()); Assertions.assertEquals(512, config.getGlobalThreadPoolQueueSize().longValue());
Assertions.assertEquals(ParseModeEnum.PARSE_ALL_ON_START, config.getParseMode()); Assertions.assertEquals(ParseModeEnum.PARSE_ALL_ON_START, config.getParseMode());
} }