in notification/src/main/java/org/opensearch/alerting/destination/client/DestinationEmailClient.java [34:83]
public String execute(BaseMessage message) throws Exception {
if (message instanceof EmailMessage) {
EmailMessage emailMessage = (EmailMessage) message;
Session session = null;
Properties prop = new Properties();
prop.put("mail.transport.protocol", "smtp");
prop.put("mail.smtp.host", emailMessage.getHost());
prop.put("mail.smtp.port", emailMessage.getPort());
if (emailMessage.getUsername() != null && !emailMessage.getUsername().equals("".toCharArray())) {
prop.put("mail.smtp.auth", true);
try {
session = Session.getInstance(prop, new Authenticator() {
protected PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication(
emailMessage.getUsername().toString(),
emailMessage.getPassword().toString());
}
});
} catch (IllegalStateException e) {
return e.getMessage();
}
} else {
session = Session.getInstance(prop);
}
switch(emailMessage.getMethod()) {
case "ssl":
prop.put("mail.smtp.ssl.enable", true);
break;
case "starttls":
prop.put("mail.smtp.starttls.enable", true);
break;
}
try {
Message mailmsg = new MimeMessage(session);
mailmsg.setFrom(new InternetAddress(emailMessage.getFrom()));
mailmsg.setRecipients(Message.RecipientType.TO, getRecipientsAsAddresses(emailMessage.getRecipients()));
mailmsg.setSubject(emailMessage.getSubject());
mailmsg.setText(emailMessage.getMessageContent());
SendMessage(mailmsg);
} catch (MessagingException e) {
throw new MessagingException(e.getMessage());
}
}
return "Sent";
}