public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-06-12 13:51:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

bug #IAD2HH 希望支持执行节点日志与监控日志的分开管理

Browse Source
This commit is contained in:
everywhere.z
2024-07-17 11:36:53 +08:00
parent 0b2481959f
commit cca0de3567
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
liteflow-core/src/main/java/com/yomahub/liteflow/monitor/MonitorBus.java
View File

@@ -13,6 +13,8 @@ import com.yomahub.liteflow.log.LFLoggerManager;
import com.yomahub.liteflow.property.LiteflowConfig;
import com.yomahub.liteflow.slot.DataBus;
import com.yomahub.liteflow.util.BoundedPriorityBlockingQueue;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.math.BigDecimal;
import java.math.RoundingMode;
@@ -33,7 +35,7 @@ public class MonitorBus {
private LiteflowConfig liteflowConfig;
private final LFLog LOG = LFLoggerManager.getLogger(this.getClass());
private final Logger LOG = LoggerFactory.getLogger(this.getClass());
private final ConcurrentHashMap<String, BoundedPriorityBlockingQueue<CompStatistics>> statisticsMap = new ConcurrentHashMap<>();