Răsfoiți Sursa

feature #I3ZVEA 流程组件支持重试

bryan31 3 ani în urmă
părinte
comite
3107df064e

+ 1 - 1
liteflow-spring-boot-starter/src/main/resources/META-INF/additional-spring-configuration-metadata.json

@@ -54,7 +54,7 @@
       "defaultValue": false
     },
     {
-      "name": "liteflow.retry_count",
+      "name": "liteflow.retry-count",
       "type": "java.lang.Integer",
       "description": "Number of component retries.",
       "sourceType": "com.yomahub.liteflow.springboot.LiteflowProperty",

+ 8 - 6
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/retry/LiteflowRetrySpringbootTest.java → liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/cmpRetry/LiteflowRetrySpringbootTest.java

@@ -1,4 +1,4 @@
-package com.yomahub.liteflow.test.retry;
+package com.yomahub.liteflow.test.cmpRetry;
 
 import com.yomahub.liteflow.core.FlowExecutor;
 import com.yomahub.liteflow.entity.data.DefaultSlot;
@@ -14,24 +14,26 @@ import org.springframework.context.annotation.ComponentScan;
 import org.springframework.test.context.TestPropertySource;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import javax.annotation.Resource;
+
 
 /**
- * 测试springboot下的enable参数
+ * 测试springboot下的组件重试
  * @author Bryan.Zhang
  * @since 2.5.10
  */
 @RunWith(SpringRunner.class)
-@TestPropertySource(value = "classpath:/retry/application.properties")
+@TestPropertySource(value = "classpath:/cmpRetry/application.properties")
 @SpringBootTest(classes = LiteflowRetrySpringbootTest.class)
 @EnableAutoConfiguration
-@ComponentScan({"com.yomahub.liteflow.test.retry.cmp"})
+@ComponentScan({"com.yomahub.liteflow.test.cmpRetry.cmp"})
 public class LiteflowRetrySpringbootTest extends BaseTest {
 
-    @Autowired
+    @Resource
     private FlowExecutor flowExecutor;
 
     @Test
-    public void testConfig() {
+    public void testRetry() {
         LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain1", "arg");
         Assert.assertTrue(response.isSuccess());
         Assert.assertEquals("a==>b==>b==>b==>c==>a==>d", response.getSlot().printStep());

+ 1 - 1
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/retry/cmp/ACmp.java → liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/cmpRetry/cmp/ACmp.java

@@ -5,7 +5,7 @@
  * @email weenyc31@163.com
  * @Date 2020/4/1
  */
-package com.yomahub.liteflow.test.retry.cmp;
+package com.yomahub.liteflow.test.cmpRetry.cmp;
 
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.core.NodeComponent;

+ 1 - 1
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/retry/cmp/BCmp.java → liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/cmpRetry/cmp/BCmp.java

@@ -5,7 +5,7 @@
  * @email weenyc31@163.com
  * @Date 2020/4/1
  */
-package com.yomahub.liteflow.test.retry.cmp;
+package com.yomahub.liteflow.test.cmpRetry.cmp;
 
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.core.NodeComponent;

+ 1 - 1
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/retry/cmp/CCmp.java → liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/cmpRetry/cmp/CCmp.java

@@ -5,7 +5,7 @@
  * @email weenyc31@163.com
  * @Date 2020/4/1
  */
-package com.yomahub.liteflow.test.retry.cmp;
+package com.yomahub.liteflow.test.cmpRetry.cmp;
 
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.core.NodeComponent;

+ 1 - 1
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/retry/cmp/DCmp.java → liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/cmpRetry/cmp/DCmp.java

@@ -5,7 +5,7 @@
  * @email weenyc31@163.com
  * @Date 2020/4/1
  */
-package com.yomahub.liteflow.test.retry.cmp;
+package com.yomahub.liteflow.test.cmpRetry.cmp;
 
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.core.NodeComponent;

+ 3 - 0
liteflow-spring-boot-starter/src/test/resources/cmpRetry/application.properties

@@ -0,0 +1,3 @@
+liteflow.rule-source=cmpRetry/flow.xml
+liteflow.retry-count=3
+liteflow.slot-size=512

+ 0 - 0
liteflow-spring-boot-starter/src/test/resources/retry/flow.xml → liteflow-spring-boot-starter/src/test/resources/cmpRetry/flow.xml


+ 0 - 2
liteflow-spring-boot-starter/src/test/resources/retry/application.properties

@@ -1,2 +0,0 @@
-liteflow.rule-source=retry/flow.xml
-liteflow.retry-count=3