diff --git a/jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/configuration/RuleEngineConfiguration.java b/jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/configuration/RuleEngineConfiguration.java index bf020018..38891d76 100644 --- a/jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/configuration/RuleEngineConfiguration.java +++ b/jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/configuration/RuleEngineConfiguration.java @@ -2,12 +2,14 @@ package org.jetlinks.community.rule.engine.configuration; import lombok.extern.slf4j.Slf4j; import org.jetlinks.community.rule.engine.commons.TermsConditionEvaluator; +import org.jetlinks.core.cluster.ClusterManager; import org.jetlinks.core.event.EventBus; import org.jetlinks.rule.engine.api.RuleEngine; import org.jetlinks.rule.engine.api.scheduler.Scheduler; import org.jetlinks.rule.engine.api.task.ConditionEvaluator; import org.jetlinks.rule.engine.api.task.TaskExecutorProvider; import org.jetlinks.rule.engine.api.worker.Worker; +import org.jetlinks.rule.engine.cluster.worker.ClusterWorker; import org.jetlinks.rule.engine.condition.ConditionEvaluatorStrategy; import org.jetlinks.rule.engine.condition.DefaultConditionEvaluator; import org.jetlinks.rule.engine.condition.supports.DefaultScriptEvaluator; @@ -58,7 +60,7 @@ public class RuleEngineConfiguration { @Bean public BeanPostProcessor autoRegisterStrategy(DefaultRuleModelParser defaultRuleModelParser, DefaultConditionEvaluator defaultConditionEvaluator, - LocalWorker worker) { + ClusterWorker worker) { return new BeanPostProcessor() { @Override public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException { @@ -94,8 +96,8 @@ public class RuleEngineConfiguration { } @Bean - public LocalWorker localWorker(EventBus eventBus, ConditionEvaluator evaluator) { - return new LocalWorker("local", "local", eventBus, evaluator); + public ClusterWorker localWorker(EventBus eventBus, ClusterManager clusterManager, ConditionEvaluator evaluator) { + return new ClusterWorker("local", "local", eventBus,clusterManager, evaluator); }