From 566ebcf6e49176ee0a5490ae9bf7528835f34f70 Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Fri, 11 Oct 2024 12:34:14 +0800 Subject: [PATCH] =?UTF-8?q?feature=20#IAJD9H=20=E6=9C=9F=E6=9C=9Bliteflow?= =?UTF-8?q?=20=E6=9C=89=E8=87=AA=E5=B7=B1=E7=9A=84=E7=94=9F=E5=91=BD?= =?UTF-8?q?=E5=91=A8=E6=9C=9F=E6=89=A9=E5=B1=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../liteflow/solon/integration/XPluginImpl.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/liteflow-solon-plugin/src/main/java/com/yomahub/liteflow/solon/integration/XPluginImpl.java b/liteflow-solon-plugin/src/main/java/com/yomahub/liteflow/solon/integration/XPluginImpl.java index db3c8156d..4a0abd10d 100644 --- a/liteflow-solon-plugin/src/main/java/com/yomahub/liteflow/solon/integration/XPluginImpl.java +++ b/liteflow-solon-plugin/src/main/java/com/yomahub/liteflow/solon/integration/XPluginImpl.java @@ -49,16 +49,16 @@ public class XPluginImpl implements Plugin { context.beanMake(LiteflowMainAutoConfiguration.class); // 订阅生命周期实现类 - context.subWrapsOfType(LifeCycle.class, bw -> { - LifeCycle lifeCycle = bw.raw(); - LifeCycleHolder.addLifeCycle(lifeCycle); - }); + context.subBeansOfType(LifeCycle.class, LifeCycleHolder::addLifeCycle); // 订阅 NodeComponent 组件 - context.subWrapsOfType(NodeComponent.class, bw -> { - NodeComponent node1 = bw.raw(); - node1.setNodeId(bw.name()); - FlowBus.addManagedNode(bw.name(), bw.raw()); + context.lifecycle(()-> { + //扫描完成后，收集组件 + context.beanForeach(bw -> { + if (bw.raw() instanceof NodeComponent) { + FlowBus.addManagedNode(bw.name(), bw.raw()); + } + }); }); Set> liteflowMethodClassSet = new HashSet<>();