19

I need to send a email in async way while saving the data into DB.

My approach was like this.

//I have tried with service layer annotating.But not worked. 
@EnableAsync 
class MyService{
 public String saveMethod(List listOfData){
    mail.sendEmailQuote(listOfData);
    mail.sendEmailWorkflowTaskAssignment(listOfData);
    myDao.saveData(listOfData);
 }
}

I need to perform following methods in @Async way. Where should I put @EnableAsync annotation. This is not a Schedule related thing. This is happen when user click save button. Application is used flex spring blazeDS. There is no controller written by my self.

I have used @Async annotation in my code for following 2 methods. Those are in class call Mail.

@Async
sendEmailQuote(listOfData){}

@Async
sendEmailWorkflowTaskAssignment(listOfData){}

Could you help me to find where should I put @EnableAsync ?

I refer this sample

Sanka
  • 1,294
  • 1
  • 11
  • 20

2 Answers2

22

EnableAsync is used for configuration and enable Spring's asynchronous method execution capability, it should not be put on your Service or Component class, it should be put on your Configuration class like:

@Configuration
@EnableAsync
public class AppConfig {

}

Or with more configuration of your AsyncExecutor like:

@Configuration
@EnableAsync
public class AppConfig implements AsyncConfigurer {

 @Override
 public Executor getAsyncExecutor() {
     ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
     executor.setCorePoolSize(7);
     executor.setMaxPoolSize(42);
     executor.setQueueCapacity(11);
     executor.setThreadNamePrefix("MyExecutor-");
     executor.initialize();
     return executor;
 }
 }

Please refer to it's java doc for more details.

And for the tutorial you followed, EnableAsync is put above Application class, which extends AsyncConfigurerSupport with AsyncExecutor configuration:

@SpringBootApplication
@EnableAsync
public class Application extends AsyncConfigurerSupport {

public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
}

@Override
public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(2);
    executor.setMaxPoolSize(2);
    executor.setQueueCapacity(500);
    executor.setThreadNamePrefix("GithubLookup-");
    executor.initialize();
    return executor;
}
}
codingbiz
  • 26,179
  • 8
  • 59
  • 96
shizhz
  • 11,715
  • 3
  • 39
  • 49
  • 1
    If you follow https://spring.io/guides/gs/async-method/ step by step, it will work. The correct config would be: 1. `@Service` is above your `MyService` class; 2. `@Async` is above your method in `MyService` , 3. `@EnableAsync`, also with `@SpringBootApplication` be above your `Application` class. Or could you please post all your code already tried? – shizhz Apr 06 '17 at 03:37
  • 1
    what if I want use it in spring project,not springboot project? – keith5140 Nov 13 '18 at 05:42
18

Just make sure that @Async methods aren't called by the same class. Self invocation for proxy won't work.

watts
  • 313
  • 3
  • 10