diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/monitor/MonitorBus.java b/liteflow-core/src/main/java/com/yomahub/liteflow/monitor/MonitorBus.java index a37039a4b..6eab35a23 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/monitor/MonitorBus.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/monitor/MonitorBus.java @@ -43,6 +43,14 @@ public class MonitorBus { private ConcurrentHashMap> statisticsMap = new ConcurrentHashMap>(); + public MonitorBus(boolean enableMonitorLog) { + this.enableMonitorLog = enableMonitorLog; + if(this.enableMonitorLog){ + Timer timer = new Timer(); + timer.schedule(new MonitorTimeTask(this), this.getDelay(), this.getPeriod()); + } + } + public MonitorBus(boolean enableMonitorLog, int queueLimit, long delay, long period) { this.enableMonitorLog = enableMonitorLog; this.queueLimit = queueLimit; diff --git a/liteflow-test-spring/src/main/resources/applicationContext.xml b/liteflow-test-spring/src/main/resources/applicationContext.xml index 4a1ba551c..473b44df8 100644 --- a/liteflow-test-spring/src/main/resources/applicationContext.xml +++ b/liteflow-test-spring/src/main/resources/applicationContext.xml @@ -19,4 +19,8 @@ + + + +