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 317a667e4..278b4d3f2 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 @@ -47,6 +47,8 @@ public class MonitorBus { private final ConcurrentHashMap> statisticsMap = new ConcurrentHashMap<>(); public MonitorBus(LiteflowConfig liteflowConfig) { + this.liteflowConfig = liteflowConfig; + if (ObjectUtil.isNotNull(liteflowConfig.getEnableLog())){ this.enableLog = liteflowConfig.getEnableLog(); } diff --git a/liteflow-test-springboot/src/main/java/com/yomahub/flowtest/Runner.java b/liteflow-test-springboot/src/main/java/com/yomahub/flowtest/Runner.java index 86fb82f00..d3cdf278b 100644 --- a/liteflow-test-springboot/src/main/java/com/yomahub/flowtest/Runner.java +++ b/liteflow-test-springboot/src/main/java/com/yomahub/flowtest/Runner.java @@ -10,7 +10,7 @@ public class Runner { try{ SpringApplication.run(Runner.class, args); - System.exit(0); +// System.exit(0); }catch (Throwable t){ t.printStackTrace(); } diff --git a/liteflow-test-springboot/src/main/resources/application.properties b/liteflow-test-springboot/src/main/resources/application.properties index 2cabc8c86..e9f5d279b 100644 --- a/liteflow-test-springboot/src/main/resources/application.properties +++ b/liteflow-test-springboot/src/main/resources/application.properties @@ -1 +1,7 @@ -liteflow.rule-source=config/flow.xml \ No newline at end of file +liteflow.rule-source=config/flow.xml +liteflow.slot-size=2048 +liteflow.when-max-wait-second=20 +liteflow.monitor.enable-log=true +liteflow.monitor.queue-limit=300 +liteflow.monitor.delay=10000 +liteflow.monitor.period=10000 \ No newline at end of file