源码分析:规则引擎提交策略
admin
2024-04-04 20:45:34
0次
【任务提交】 规则引擎从 kafka 队列消费到数据后,会按照不同的提交策略和处理策略将消息输入进规则链[传入RuleEngineActor顶层Actor],RuleEngineActor在执行完传递后会调用成功或失败,然后再执行下一条、下一批的输入: 【日志分析】 提交时获取提交策略: //TbRuleEngineQueueConfiguration( // name=Main, // topic=tb_rule_engine.main, // pollInterval=25, // partitions=10,
相关内容