public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 04:02:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

执行器支持slot的泛型

Browse Source
This commit is contained in:
bryan.zhang
2018-01-05 16:22:45 +08:00
parent 3a49b81281
commit 014666e710
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/thebeastshop/liteflow/core/FlowExecutor.java
View File

@@ -54,11 +54,11 @@ public class FlowExecutor {
init();
}
public Slot execute(String chainId,Object param){
public <T extends Slot> T execute(String chainId,Object param){
return execute(chainId, param, DefaultSlot.class,null,false);
}
public Slot execute(String chainId,Object param,Class<? extends Slot> slotClazz){
public <T extends Slot> T execute(String chainId,Object param,Class<? extends Slot> slotClazz){
return execute(chainId, param, slotClazz,null,false);
}
@@ -66,7 +66,7 @@ public class FlowExecutor {
execute(chainId, param, slotClazz,slotIndex,true);
}
public Slot execute(String chainId,Object param,Class<? extends Slot> slotClazz,Integer slotIndex,boolean isInnerChain){
public <T extends Slot> T execute(String chainId,Object param,Class<? extends Slot> slotClazz,Integer slotIndex,boolean isInnerChain){
try{
if(FlowBus.needInit()) {
init();
@@ -140,7 +140,7 @@ public class FlowExecutor {
if(!isInnerChain) {
slot.printStep();
}
return slot;
return (T)slot;
}catch(Exception e){
LOG.error("executor cause error",e);
throw new FlowSystemException("executor cause error");