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

|

|
||||||
|
|
||||||
|
|
|
||||||
|
Before Width: | Height: | Size: 27 KiB After Width: | Height: | Size: 27 KiB |
|
|
@ -9,7 +9,7 @@
|
||||||
<parent>
|
<parent>
|
||||||
<groupId>com.yomahub</groupId>
|
<groupId>com.yomahub</groupId>
|
||||||
<artifactId>liteflow</artifactId>
|
<artifactId>liteflow</artifactId>
|
||||||
<version>2.3.3</version>
|
<version>2.3.5</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
|
|
||||||
|
|
@ -143,6 +143,7 @@ public class FlowExecutor {
|
||||||
}catch(Exception e){
|
}catch(Exception e){
|
||||||
slot.setSuccess(false);
|
slot.setSuccess(false);
|
||||||
slot.setErrorMsg(e.getMessage());
|
slot.setErrorMsg(e.getMessage());
|
||||||
|
throw e;
|
||||||
}finally{
|
}finally{
|
||||||
if(!isInnerChain) {
|
if(!isInnerChain) {
|
||||||
slot.printStep();
|
slot.printStep();
|
||||||
|
|
|
||||||
|
|
@ -10,7 +10,7 @@
|
||||||
<parent>
|
<parent>
|
||||||
<artifactId>liteflow</artifactId>
|
<artifactId>liteflow</artifactId>
|
||||||
<groupId>com.yomahub</groupId>
|
<groupId>com.yomahub</groupId>
|
||||||
<version>2.3.3</version>
|
<version>2.3.5</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
|
|
||||||
|
|
@ -9,7 +9,7 @@
|
||||||
<parent>
|
<parent>
|
||||||
<artifactId>liteflow</artifactId>
|
<artifactId>liteflow</artifactId>
|
||||||
<groupId>com.yomahub</groupId>
|
<groupId>com.yomahub</groupId>
|
||||||
<version>2.3.3</version>
|
<version>2.3.5</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
|
|
||||||
|
|
@ -9,7 +9,7 @@
|
||||||
<parent>
|
<parent>
|
||||||
<artifactId>liteflow</artifactId>
|
<artifactId>liteflow</artifactId>
|
||||||
<groupId>com.yomahub</groupId>
|
<groupId>com.yomahub</groupId>
|
||||||
<version>2.3.3</version>
|
<version>2.3.5</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencyManagement>
|
<dependencyManagement>
|
||||||
|
|
|
||||||
|
|
@ -2,6 +2,7 @@ package com.yomahub.flowtest;
|
||||||
|
|
||||||
import com.yomahub.liteflow.core.FlowExecutor;
|
import com.yomahub.liteflow.core.FlowExecutor;
|
||||||
import com.yomahub.liteflow.entity.data.Slot;
|
import com.yomahub.liteflow.entity.data.Slot;
|
||||||
|
import com.yomahub.liteflow.exception.ChainEndException;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.boot.CommandLineRunner;
|
import org.springframework.boot.CommandLineRunner;
|
||||||
|
|
@ -17,7 +18,12 @@ public class TestFlow implements CommandLineRunner {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void run(String... args) throws Exception {
|
public void run(String... args) throws Exception {
|
||||||
Slot slot = flowExecutor.execute("chain3", "it's a request");
|
try{
|
||||||
System.out.println(slot);
|
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() {
|
public void process() {
|
||||||
try {
|
try {
|
||||||
Thread.sleep(120L);
|
Thread.sleep(120L);
|
||||||
|
this.setIsEnd(true);
|
||||||
System.out.println("E:" + this.getSlot().getOutput("a"));
|
System.out.println("E:" + this.getSlot().getOutput("a"));
|
||||||
this.getSlot().setOutput(this.getNodeId(), "E component output");
|
this.getSlot().setOutput(this.getNodeId(), "E component output");
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
|
|
|
||||||
2
pom.xml
2
pom.xml
|
|
@ -5,7 +5,7 @@
|
||||||
<groupId>com.yomahub</groupId>
|
<groupId>com.yomahub</groupId>
|
||||||
<artifactId>liteflow</artifactId>
|
<artifactId>liteflow</artifactId>
|
||||||
<packaging>pom</packaging>
|
<packaging>pom</packaging>
|
||||||
<version>2.3.3</version>
|
<version>2.3.5</version>
|
||||||
<name>liteflow</name>
|
<name>liteflow</name>
|
||||||
<description>a lightweight and practical micro-process framework</description>
|
<description>a lightweight and practical micro-process framework</description>
|
||||||
<url>https://github.com/bryan31/liteflow</url>
|
<url>https://github.com/bryan31/liteflow</url>
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue