diff --git a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ZipkinExecutorAdapter.java b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ZipkinExecutorAdapter.java index eb344c8c..9de29d56 100644 --- a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ZipkinExecutorAdapter.java +++ b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ZipkinExecutorAdapter.java @@ -23,6 +23,7 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.lang.reflect.Field; import java.util.Objects; +import java.util.Optional; import java.util.concurrent.Executor; /** @@ -40,10 +41,10 @@ public class ZipkinExecutorAdapter implements DynamicThreadPoolAdapter { } public boolean matchSuper(Object executor) { - if (Objects.equals(MATCH_CLASS_NAME, executor.getClass().getName())) { + if (Objects.equals(MATCH_CLASS_NAME, Optional.ofNullable(executor).map(Object::getClass).map(Class::getName).orElse(null))) { return true; } else { - return Objects.equals(MATCH_CLASS_NAME, executor.getClass().getSuperclass().getName()); + return Objects.equals(MATCH_CLASS_NAME, Optional.ofNullable(executor).map(Object::getClass).map(Class::getSuperclass).map(Class::getName).orElse(null)); } }