Compare commits
4 Commits
| Author | SHA1 | Date |
|---|---|---|
|
|
c6ef1be10a | |
|
|
b8422ca5ff | |
|
|
caff45c537 | |
|
|
f4f3ec5b0f |
|
|
@ -19,5 +19,5 @@ liteFlow是一个轻量,快速的组件式流程引擎框架,组件编排,
|
|||
|
||||
关注公众号回复`liteflow`即可加入讨论群
|
||||
|
||||

|
||||

|
||||
|
||||
|
|
|
|||
|
Before Width: | Height: | Size: 27 KiB After Width: | Height: | Size: 27 KiB |
|
|
@ -9,7 +9,7 @@
|
|||
<parent>
|
||||
<groupId>com.yomahub</groupId>
|
||||
<artifactId>liteflow</artifactId>
|
||||
<version>2.3.3</version>
|
||||
<version>2.3.5</version>
|
||||
</parent>
|
||||
|
||||
<dependencies>
|
||||
|
|
|
|||
|
|
@ -143,6 +143,7 @@ public class FlowExecutor {
|
|||
}catch(Exception e){
|
||||
slot.setSuccess(false);
|
||||
slot.setErrorMsg(e.getMessage());
|
||||
throw e;
|
||||
}finally{
|
||||
if(!isInnerChain) {
|
||||
slot.printStep();
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@
|
|||
<parent>
|
||||
<artifactId>liteflow</artifactId>
|
||||
<groupId>com.yomahub</groupId>
|
||||
<version>2.3.3</version>
|
||||
<version>2.3.5</version>
|
||||
</parent>
|
||||
|
||||
<dependencies>
|
||||
|
|
|
|||
|
|
@ -9,7 +9,7 @@
|
|||
<parent>
|
||||
<artifactId>liteflow</artifactId>
|
||||
<groupId>com.yomahub</groupId>
|
||||
<version>2.3.3</version>
|
||||
<version>2.3.5</version>
|
||||
</parent>
|
||||
|
||||
<dependencies>
|
||||
|
|
|
|||
|
|
@ -9,7 +9,7 @@
|
|||
<parent>
|
||||
<artifactId>liteflow</artifactId>
|
||||
<groupId>com.yomahub</groupId>
|
||||
<version>2.3.3</version>
|
||||
<version>2.3.5</version>
|
||||
</parent>
|
||||
|
||||
<dependencyManagement>
|
||||
|
|
|
|||
|
|
@ -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();
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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) {
|
||||
|
|
|
|||
2
pom.xml
2
pom.xml
|
|
@ -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>
|
||||
|
|
|
|||
Loading…
Reference in New Issue