isAccess方法改为如果为false则跳过当前组件

This commit is contained in:
bryan.zhang
2018-01-08 17:25:13 +08:00
parent 2e90ea7a81
commit 36acacefbd
3 changed files with 3 additions and 6 deletions

View File

@@ -5,7 +5,7 @@
<artifactId>liteflow</artifactId> <artifactId>liteflow</artifactId>
<packaging>jar</packaging> <packaging>jar</packaging>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>1.2.7</version> <version>1.2.8</version>
<properties> <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

View File

@@ -118,9 +118,6 @@ public class FlowExecutor {
LOG.info("component[{}] lead the chain to end",component.getClass().getSimpleName()); LOG.info("component[{}] lead the chain to end",component.getClass().getSimpleName());
break; break;
} }
}else{
String errorMsg = MessageFormat.format("component[{0}] do not gain access", component.getClass().getSimpleName());
throw new ComponentNotAccessException(errorMsg);
} }
}catch(Throwable t){ }catch(Throwable t){
if(component.isContinueOnError()){ if(component.isContinueOnError()){

View File

@@ -49,9 +49,9 @@ public class DataBus {
if(slots[slotIndex] != null){ if(slots[slotIndex] != null){
slots[slotIndex] = null; slots[slotIndex] = null;
OCCUPY_COUNT.decrementAndGet(); OCCUPY_COUNT.decrementAndGet();
LOG.info("the slot[{}] released",slotIndex); LOG.info("slot[{}] released",slotIndex);
}else{ }else{
LOG.warn("the slot[{}] has been released",slotIndex); LOG.warn("slot[{}] already has been released",slotIndex);
} }
} }
} }