public void activate()

in src/main/java/org/apache/sling/jobs/it/services/AsyncJobConsumer.java [104:111]

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

    public void activate(Map<String, Object> properites) {
        int corePoolSize = (int) properites.get(CORE_THREAD_POOL_SIZE);
        int maxPoolSize = (int) properites.get(MAC_THREAD_POOL_SIZE);
        int maxBacklog = (int) properites.get(MAX_QUEUED_BACKLOG);
        shutdownWaitSeconds = (long) properites.get(SHUTDOWN_WAIT_SECONDS);
        workQueue = new LinkedBlockingQueue<Runnable>(maxBacklog);
        executor = new ThreadPoolExecutor(corePoolSize, maxPoolSize, 60, TimeUnit.SECONDS, workQueue);
    }