Enabled async sending of mails. Closes #15

pull/21/head
Niclas Thobaben 2022-02-14 21:48:57 +01:00
parent b1cb69080a
commit 5a68b1484a
2 changed files with 6 additions and 0 deletions

View File

@ -3,9 +3,11 @@ package de.nclazz.service.mailrelay;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableAsync;
import java.time.Clock; import java.time.Clock;
@EnableAsync
@SpringBootApplication @SpringBootApplication
public class MailRelayApplication { public class MailRelayApplication {

View File

@ -6,6 +6,7 @@ import lombok.RequiredArgsConstructor;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import org.springframework.mail.javamail.JavaMailSender; import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper; import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.mail.internet.MimeMessage; import javax.mail.internet.MimeMessage;
@ -17,11 +18,14 @@ public class MailMessageForwarder implements MessageForwarder {
private final JavaMailSender javaMailSender; private final JavaMailSender javaMailSender;
@Async
@SneakyThrows @SneakyThrows
@Override @Override
public void forwardMessage(@NonNull String subject, @NonNull String content, public void forwardMessage(@NonNull String subject, @NonNull String content,
@NonNull String from, @NonNull List<String> receivers) { @NonNull String from, @NonNull List<String> receivers) {
MimeMessage mimeMessage = this.javaMailSender.createMimeMessage(); MimeMessage mimeMessage = this.javaMailSender.createMimeMessage();
MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage, false, "UTF-8"); MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage, false, "UTF-8");
mimeMessageHelper.setFrom(from); mimeMessageHelper.setFrom(from);