SBHWR-14: added async email executor

src/main/java/org/wyona/webapp/config/AsyncExecutorConfig.java

@@ -0,0 +1,43 @@
+package org.wyona.webapp.config;
+
+import java.util.concurrent.Executor;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+@EnableAsync
+@ConfigurationProperties(prefix = "email.executor")
+public class AsyncExecutorConfig
+{
+
+  private int maxThreads;
+  private int maxPoolSize;
+  private int corePoolSize;
+
+  @Bean(name = "emailAsyncExecutor")
+  public Executor asyncExecutor()
+  {
+    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+    executor.setCorePoolSize(corePoolSize);
+    executor.setMaxPoolSize(maxPoolSize);
+    executor.setQueueCapacity(maxThreads);
+    executor.setThreadNamePrefix("EmailAsyncExecutorThread-");
+    executor.initialize();
+    return executor;
+  }
+
+  public void setMaxThreads(int maxThreads) {
+    this.maxThreads = maxThreads;
+  }
+
+  public void setMaxPoolSize(int maxPoolSize) {
+    this.maxPoolSize = maxPoolSize;
+  }
+
+  public void setCorePoolSize(int corePoolSize) {
+    this.corePoolSize = corePoolSize;
+  }
+}

src/main/java/org/wyona/webapp/mail/AsyncEmailSender.java

@@ -0,0 +1,22 @@
+package org.wyona.webapp.mail;
+
+import javax.mail.Message;
+import javax.mail.MessagingException;
+import javax.mail.Transport;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+@Component
+public class AsyncEmailSender {
+
+  private final static Logger LOGGER = LoggerFactory.getLogger(AsyncEmailSender.class);
+
+  @Async("emailAsyncExecutor")
+  public void sendMailAsync(final Message message) throws MessagingException {
+    LOGGER.info("Async method started");
+    Transport.send(message) ;
+    LOGGER.info("Async method completed");
+  }
+}

src/main/java/org/wyona/webapp/mail/EmailSender.java

@@ -28,9 +28,12 @@ public class EmailSender {
     @Value("${from.email.address}")
     private String fromEmail;
 
+    private AsyncEmailSender asyncEmailSender;
+
     @Autowired
-    public EmailSender(EmailSenderCofig config, EmailValidation emailValidation){
+    public EmailSender(EmailSenderCofig config, EmailValidation emailValidation, AsyncEmailSender asyncEmailSender){
         this.emailValidation = emailValidation;
+        this.asyncEmailSender = asyncEmailSender;
 
         Properties props = new Properties();
         props.put("mail.transport.protocol", "smtp");
@@ -60,7 +63,7 @@ public void sendEmailGreeting(String email, String subject, String text, boolean
 
         Message message = composeMessage(email, subject, text, isHTMLMessage, attachment);
 
-        Transport.send(message);
+        asyncEmailSender.sendMailAsync(message);
     }
 
     private void validateParameters(String email, String subject, String text) {

src/main/resources/application.properties

@@ -8,6 +8,10 @@ app.mail.port=587
 app.mail.username=USERNAME
 app.mail.password=PASSWORD
 
+email.executor.corePoolSize=3
+email.executor.maxPoolSize=3
+email.executor.maxThreads=100
+
 #app.mail.host=mail.wyona.com
 #app.mail.port=587
 #app.mail.username=USERNAME