Compare commits

...

4 Commits

Author SHA1 Message Date
bryan31 c6ef1be10a 版本更新到2.3.5 2021-04-02 15:20:38 +08:00
bryan31 b8422ca5ff 版本更新到2.3.5 2021-04-02 14:22:16 +08:00
bryan31 caff45c537 增加FlowExecutor的异常抛出 2021-04-02 14:18:36 +08:00
bryan31 f4f3ec5b0f 更新readme 2020-11-05 00:18:02 +08:00
10 changed files with 16 additions and 8 deletions

View File

@ -19,5 +19,5 @@ liteFlow是一个轻量快速的组件式流程引擎框架组件编排
关注公众号回复`liteflow`即可加入讨论群
![offIical-wx](http://yomahub.com/images/offIical-wx.jpg)
![offIical-wx](/docs/media/offical-wx.jpg)

View File

Before

Width:  |  Height:  |  Size: 27 KiB

After

Width:  |  Height:  |  Size: 27 KiB

View File

@ -9,7 +9,7 @@
<parent>
<groupId>com.yomahub</groupId>
<artifactId>liteflow</artifactId>
<version>2.3.3</version>
<version>2.3.5</version>
</parent>
<dependencies>

View File

@ -143,6 +143,7 @@ public class FlowExecutor {
}catch(Exception e){
slot.setSuccess(false);
slot.setErrorMsg(e.getMessage());
throw e;
}finally{
if(!isInnerChain) {
slot.printStep();

View File

@ -10,7 +10,7 @@
<parent>
<artifactId>liteflow</artifactId>
<groupId>com.yomahub</groupId>
<version>2.3.3</version>
<version>2.3.5</version>
</parent>
<dependencies>

View File

@ -9,7 +9,7 @@
<parent>
<artifactId>liteflow</artifactId>
<groupId>com.yomahub</groupId>
<version>2.3.3</version>
<version>2.3.5</version>
</parent>
<dependencies>

View File

@ -9,7 +9,7 @@
<parent>
<artifactId>liteflow</artifactId>
<groupId>com.yomahub</groupId>
<version>2.3.3</version>
<version>2.3.5</version>
</parent>
<dependencyManagement>

View File

@ -2,6 +2,7 @@ package com.yomahub.flowtest;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.entity.data.Slot;
import com.yomahub.liteflow.exception.ChainEndException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
@ -17,7 +18,12 @@ public class TestFlow implements CommandLineRunner {
@Override
public void run(String... args) throws Exception {
Slot slot = flowExecutor.execute("chain3", "it's a request");
System.out.println(slot);
try{
Slot slot = flowExecutor.execute("chain1", "it's a request");
System.out.println(slot);
}catch (ChainEndException e){
e.printStackTrace();
}
}
}

View File

@ -17,6 +17,7 @@ public class EComponent extends NodeComponent {
public void process() {
try {
Thread.sleep(120L);
this.setIsEnd(true);
System.out.println("E:" + this.getSlot().getOutput("a"));
this.getSlot().setOutput(this.getNodeId(), "E component output");
} catch (InterruptedException e) {

View File

@ -5,7 +5,7 @@
<groupId>com.yomahub</groupId>
<artifactId>liteflow</artifactId>
<packaging>pom</packaging>
<version>2.3.3</version>
<version>2.3.5</version>
<name>liteflow</name>
<description>a lightweight and practical micro-process framework</description>
<url>https://github.com/bryan31/liteflow</url>