From a67fa656ba9fe0b26302edc7187b869007891369 Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Sat, 10 Jun 2023 14:47:49 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=8E=B7=E5=8F=96=E4=B8=8A?= =?UTF-8?q?=E4=B8=8B=E6=96=87=E7=9A=84=E9=80=BB=E8=BE=91=E4=BB=A5=E9=81=BF?= =?UTF-8?q?=E5=85=8D=E5=9C=A8=E7=83=AD=E9=83=A8=E7=BD=B2=E6=8F=92=E4=BB=B6?= =?UTF-8?q?=E7=9A=84=E7=8E=AF=E5=A2=83=E4=B8=8B=E6=9C=89=E5=8F=AF=E8=83=BD?= =?UTF-8?q?=E4=BC=9A=E5=BC=95=E8=B5=B7=E7=9A=84=E5=90=8C=E7=B1=BB=E7=94=B1?= =?UTF-8?q?=E5=A4=9A=E4=B8=AA=E7=B1=BB=E5=8A=A0=E8=BD=BD=E5=BC=95=E8=B5=B7?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/yomahub/liteflow/slot/Slot.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java b/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java index 91ced72d7..49f0cd161 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java @@ -28,6 +28,7 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedDeque; import java.util.concurrent.ConcurrentLinkedQueue; +import java.util.function.Consumer; /** * Slot的抽象类实现 @@ -388,8 +389,9 @@ public class Slot { } public T getContextBean(Class contextBeanClazz) { - T t = (T) contextBeanList.stream().filter(o -> o.getClass().equals(contextBeanClazz)).findFirst().orElse(null); + T t = (T) contextBeanList.stream().filter(o -> o.getClass().getName().equals(contextBeanClazz.getName())).findFirst().orElse(null); if (t == null) { + contextBeanList.forEach(o -> LOG.info("ChainId[{}], Context class:{},Request class:{}", this.getChainId(), o.getClass().getName(), contextBeanClazz.getName())); throw new NoSuchContextBeanException("this type is not in the context type passed in"); } return t;