Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.config;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.annotation.EnableAsync;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

/**

 * Configuration for async processing of Solr updates.

 * Enables non-blocking Solr updates when TagListing changes.

 */

@Configuration

@EnableAsync

public class AsyncConfig {

    @Bean(name = "solrUpdateExecutor")

    public Executor solrUpdateExecutor() {

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

        executor.setCorePoolSize(2);

        executor.setMaxPoolSize(5);

        executor.setQueueCapacity(100);

        executor.setThreadNamePrefix("solr-update-");

        executor.initialize();

        return executor;

    }

    @Bean(name = "mailOutboxExecutor")

    public Executor mailOutboxExecutor() {

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

        executor.setCorePoolSize(2);

        executor.setMaxPoolSize(5);

        executor.setQueueCapacity(200);

        executor.setThreadNamePrefix("mail-outbox-");

        executor.initialize();

        return executor;

    }

    /**

     * Fetches LMS call recordings from the telephony provider into our object store. Single-threaded

     * on purpose: these are multi-MB downloads and the point is to drain them steadily in the

     * background, not to saturate the link the moment a busy hour ends.

     */

    @Bean(name = "recordingArchiveExecutor")

    public Executor recordingArchiveExecutor() {

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

        executor.setCorePoolSize(1);

        executor.setMaxPoolSize(2);

        executor.setQueueCapacity(500);

        executor.setThreadNamePrefix("recording-archive-");

        executor.initialize();

        return executor;

    }

    @Bean(name = "priceHikeExecutor")

    public Executor priceHikeExecutor() {

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

        executor.setCorePoolSize(1);

        executor.setMaxPoolSize(3);

        executor.setQueueCapacity(100);

        executor.setThreadNamePrefix("price-hike-");

        executor.initialize();

        return executor;

    }

}