public ThreadPoolProfile threadPool()

in core/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/threadpool/CamelThreadPoolAutoConfiguration.java [36:71]

30 lines of code
4 McCabe index (conditional complexity)


    public ThreadPoolProfile threadPool(CamelContext camelContext, CamelThreadPoolConfigurationProperties tp) {
        if (tp.isEmpty()) {
            return null;
        }

        // okay we have all properties set so we should be able to create thread pool profiles and register them on camel
        ThreadPoolProfile defaultProfile = camelContext.getExecutorServiceManager().getDefaultThreadPoolProfile();
        final ThreadPoolProfile dp = new ThreadPoolProfileBuilder("default", defaultProfile)
                .poolSize(tp.getPoolSize())
                .maxPoolSize(tp.getMaxPoolSize())
                .keepAliveTime(tp.getKeepAliveTime(), tp.getTimeUnit())
                .maxQueueSize(tp.getMaxQueueSize())
                .allowCoreThreadTimeOut(tp.getAllowCoreThreadTimeOut())
                .rejectedPolicy(tp.getRejectedPolicy()).build();

        tp.getConfig().forEach((k, v) -> {
            ThreadPoolProfileBuilder builder = new ThreadPoolProfileBuilder(k, dp);
            final ThreadPoolProfile tpp = builder.poolSize(v.getPoolSize())
                    .maxPoolSize(v.getMaxPoolSize())
                    .keepAliveTime(v.getKeepAliveTime(), v.getTimeUnit())
                    .maxQueueSize(v.getMaxQueueSize())
                    .allowCoreThreadTimeOut(v.getAllowCoreThreadTimeOut())
                    .rejectedPolicy(v.getRejectedPolicy()).build();
            if (!tpp.isEmpty()) {
                camelContext.getExecutorServiceManager().registerThreadPoolProfile(tpp);
            }
        });

        if (!dp.isEmpty()) {
            dp.setDefaultProfile(true);
            camelContext.getExecutorServiceManager().setDefaultThreadPoolProfile(dp);
        }

        // need to return something
        return dp;
    }