🌵Other environment
LiteflowConfig config = new LiteflowConfig();
//rule file path
config.setRuleSource("config/flow.el.xml");
//-----------------The following configs are optional-----------------
//Whether liteflow is enabled, the default is true
config.setEnable(true);
//Whether the banner of liteflow is enabled, the default is true
config.setPrintBanner(true);
//The node of zkNode, only works when zk is used as the configuration source
config.setZkNode("/lite-flow/flow");
//Maximum number of slots for context, default is 1024
config.setSlotSize(1024);
//The number of threads of the execute2Future of FlowExecutor, the default is 64
config.setMainExecutorWorks(64);
//FlowExecutor's execute2Future's custom thread pool Builder, LiteFlow provides the default Builder
config.setMainExecutorClass("com.yomahub.liteflow.thread.LiteFlowDefaultMainExecutorBuilder");
//Custom request ID generation class, LiteFlow provides a default generation class
config.setRequestIdGeneratorClass("com.yomahub.liteflow.flow.id.DefaultRequestIdGenerator");
//Thread pool Builder for parallel nodes, LiteFlow provides default Builder
config.setThreadExecutorClass("com.yomahub.liteflow.thread.LiteFlowDefaultWhenExecutorBuilder");
//The longest waiting time in seconds for asynchronous threads (only for when), the default value is 15
config.setWhenMaxWaitSeconds(15);
//The maximum number of threads in the global asynchronous thread pool of the when node, the default is 16
config.setWhenMaxWorkers(16);
//When node global asynchronous thread pool waiting queue number, the default is 512
config.setWhenQueueLimit(512);
//Whether to parse the rules at startup, the default is true
config.setParseOnStart(true);
//Global retries, default is 0
config.setRetryCount(0);
//Whether to support mixing of different types of loading methods, the default is false
config.setSupportMultipleType(false);
//Global default node executor
config.setNodeExecutorClass("com.yomahub.liteflow.flow.executor.DefaultNodeExecutor");
//Whether to print the log during execution, the default is true
config.setPrintExecutionLog(true);
//Whether monitoring is enabled, it is disabled by default
config.setEnableLog(false);
//Monitoring queue storage size, the default value is 200
config.setQueueLimit(200);
//Monitor how many milliseconds to delay execution at the beginning, the default value is 300000 milliseconds, which is 5 minutes
config.setDelay(300000L);
//how many milliseconds the monitoring log print. The default value is 300000 milliseconds, which is 5 minutes.
config.setPeriod(300000L);
notice
rule-source
is required whenever rules are used.
But if you construct rules dynamically with code, then the rule-source
configuration is automatically invalid. Because code constructs use code to assemble rules, no rules files are required. For details, please refer to Dynamic Rules.
Help us improve this document (opens new window)
last update: 2022/10/13, 00:02:27