public Executor getAsyncExecutor()

in src/main/java/org/apache/fineract/cn/async/config/AsyncProcessingJavaConfiguration.java [49:62]

• 13 lines of code
• 1 McCabe index (conditional complexity)

  public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(
        Integer.valueOf(this.env.getProperty(AsyncConstants.CORE_POOL_SIZE_PROP, AsyncConstants.CORE_POOL_SIZE_DEFAULT)));
    executor.setMaxPoolSize(
        Integer.valueOf(this.env.getProperty(AsyncConstants.MAX_POOL_SIZE_PROP, AsyncConstants.MAX_POOL_SIZE_DEFAULT)));
    executor.setQueueCapacity(
        Integer.valueOf(this.env.getProperty(AsyncConstants.QUEUE_CAPACITY_PROP, AsyncConstants.QUEUE_CAPACITY_DEFAULT)));
    executor.setThreadNamePrefix(
        this.env.getProperty(AsyncConstants.THREAD_NAME_PROP, AsyncConstants.THREAD_NAME_DEFAULT));
    executor.initialize();

    return new DelegatingContextExecutor(new DelegatingSecurityContextAsyncTaskExecutor(executor));
  }