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

修复MonitorBus必须得注入的问题

Browse Source
This commit is contained in:
bryan31
2021-03-18 18:37:04 +08:00
parent 129a0a43fd
commit bd43e97ba4
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java
View File

@@ -7,6 +7,7 @@
*/
package com.yomahub.liteflow.core;
import cn.hutool.core.util.ObjectUtil;
import com.yomahub.liteflow.entity.flow.Executable;
import com.yomahub.liteflow.spring.ComponentScaner;
import org.apache.commons.lang3.StringUtils;
@@ -23,6 +24,7 @@ import com.yomahub.liteflow.entity.monitor.CompStatistics;
import com.yomahub.liteflow.flow.FlowBus;
import com.yomahub.liteflow.monitor.MonitorBus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.lang.Nullable;
import javax.annotation.Resource;
@@ -32,7 +34,7 @@ public abstract class NodeComponent {
private InheritableThreadLocal<Integer> slotIndexTL = new InheritableThreadLocal<Integer>();
@Resource
@Autowired(required = false)
private MonitorBus monitorBus;
private String nodeId;
@@ -68,7 +70,9 @@ public abstract class NodeComponent {
CompStatistics statistics = new CompStatistics();
statistics.setComponentClazzName(this.getClass().getSimpleName());
statistics.setTimeSpent(timeSpent);
monitorBus.addStatistics(statistics);
if (ObjectUtil.isNotNull(monitorBus)){
monitorBus.addStatistics(statistics);
}
if(this instanceof NodeCondComponent){
String condNodeId = slot.getCondResult(this.getClass().getName());