public List collectRoutesFromRegistry()

in extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/RegistryRoutesLoaders.java [55:136]
65 lines of code
15 McCabe index (conditional complexity)

        public List<RoutesBuilder> collectRoutesFromRegistry(
                CamelContext camelContext,
                String excludePattern,
                String includePattern) {

            final List<RoutesBuilder> routes = new ArrayList<>();
            final AntPathMatcher matcher = new AntPathMatcher();

            Set<LambdaRouteBuilder> lrbs = camelContext.getRegistry().findByType(LambdaRouteBuilder.class);
            for (LambdaRouteBuilder lrb : lrbs) {
                RouteBuilder rb = new RouteBuilder() {
                    @Override
                    public void configure() throws Exception {
                        lrb.accept(this);
                    }
                };
                routes.add(rb);
            }

            Set<LambdaEndpointRouteBuilder> lerbs = camelContext.getRegistry().findByType(LambdaEndpointRouteBuilder.class);
            for (LambdaEndpointRouteBuilder lerb : lerbs) {
                EndpointRouteBuilder rb = new EndpointRouteBuilder() {
                    @Override
                    public void configure() throws Exception {
                        lerb.accept(this);
                    }
                };
                routes.add(rb);
            }

            Set<RoutesBuilder> builders = camelContext.getRegistry().findByType(RoutesBuilder.class);
            for (RoutesBuilder routesBuilder : builders) {
                // filter out abstract classes
                boolean abs = Modifier.isAbstract(routesBuilder.getClass().getModifiers());
                if (!abs) {
                    String name = routesBuilder.getClass().getName();

                    // make it possible to exclude classes with RouteBuilder producer methods
                    if (name.contains("_ProducerMethod")) {
                        name = name.substring(0, name.indexOf("_ProducerMethod"));
                    }

                    // strip out extraneous naming generated by Quarkus ArC
                    name = name.replace("_ClientProxy", "");

                    // make name as path so we can use ant path matcher
                    name = name.replace('.', '/');

                    boolean match = !"false".equals(includePattern);
                    // exclude take precedence over include
                    if (match && ObjectHelper.isNotEmpty(excludePattern)) {
                        // there may be multiple separated by comma
                        String[] parts = excludePattern.split(",");
                        for (String part : parts) {
                            // must negate when excluding, and hence !
                            match = !matcher.match(part, name);
                            LOGGER.trace("Java RoutesBuilder: {} exclude filter: {} -> {}", name, part, match);
                            if (!match) {
                                break;
                            }
                        }
                    }
                    if (match && ObjectHelper.isNotEmpty(includePattern)) {
                        // there may be multiple separated by comma
                        String[] parts = includePattern.split(",");
                        for (String part : parts) {
                            match = matcher.match(part, name);
                            LOGGER.trace("Java RoutesBuilder: {} include filter: {} -> {}", name, part, match);
                            if (match) {
                                break;
                            }
                        }
                    }
                    LOGGER.debug("Java RoutesBuilder: {} accepted by include/exclude filter: {}", name, match);
                    if (match) {
                        routes.add(routesBuilder);
                    }
                }
            }

            return routes;
        }