|
@ -96,10 +96,15 @@ public class ApplicationStartListener implements ApplicationListener<ContextRefr
|
|
|
// 记录到工具类中,以便其它线程需要时进行取用
|
|
|
SystemClassMapping.getSystemClassNameMapping().put(code + BrokerConstant.ROUTE, code + CoreConstant.DOT + packageName + CoreConstant.DOT + className);
|
|
|
ClassLoader currentClassLoader = Thread.currentThread().getContextClassLoader();
|
|
|
Class<RouteBuilder> routeBuilderClass = (Class<RouteBuilder>) currentClassLoader.loadClass(SystemClassMapping.getSystemClassNameMapping().get(code + BrokerConstant.ROUTE));
|
|
|
if (routeBuilderClass != null) {
|
|
|
RouteBuilder routeBuilder = routeBuilderClass.newInstance();
|
|
|
alreadyRouteBuilders.add(routeBuilder);
|
|
|
try {
|
|
|
Class<RouteBuilder> routeBuilderClass = (Class<RouteBuilder>) currentClassLoader.loadClass(SystemClassMapping.getSystemClassNameMapping().get(code + BrokerConstant.ROUTE));
|
|
|
if (routeBuilderClass != null) {
|
|
|
RouteBuilder routeBuilder = routeBuilderClass.newInstance();
|
|
|
alreadyRouteBuilders.add(routeBuilder);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
logger.info("缺少class文件:" + code);
|
|
|
continue;
|
|
|
}
|
|
|
}
|
|
|
}
|