--- dao/DaoAdresseService/src/main/java/dk/daoas/daoadresseservice/DataLoader.java 2015/11/03 11:17:43 2767 +++ dao/DaoAdresseService/src/main/java/dk/daoas/daoadresseservice/DataLoader.java 2015/11/04 22:10:59 2768 @@ -1,7 +1,14 @@ package dk.daoas.daoadresseservice; import java.sql.SQLException; +import java.util.Properties; +import java.util.logging.Logger; +import javax.mail.Message; +import javax.mail.Session; +import javax.mail.Transport; +import javax.mail.internet.InternetAddress; +import javax.mail.internet.MimeMessage; import javax.servlet.ServletContext; import dk.daoas.daoadresseservice.admin.ServiceConfig; @@ -47,6 +54,9 @@ public static class DataLoadWorker implements Runnable { + + static final Logger logger = Logger.getLogger(DataLoadWorker.class.getName()); + DataLoader loader; public DataLoadWorker(DataLoader ld) { this.loader = ld; @@ -64,6 +74,10 @@ AddressSearch oldSearch = (AddressSearch) loader.ctxt.getAttribute("search"); loader.ctxt.setAttribute("search", search); + if (loader.config.notifyEmail != null && loader.config.notifyEmail.length() > 0) { + sendStatusEmail(search, oldSearch); + } + if (oldSearch != null) { oldSearch.clear(); } @@ -76,6 +90,31 @@ } + protected void sendStatusEmail(AddressSearch newSearch, AddressSearch oldSearch) { + Properties props = new Properties(); + props.put("mail.smtp.host", "10.30.1.28"); + + try { + // create some properties and get the default Session + Session session = Session.getDefaultInstance(props, null); + session.setDebug(false); + + + // create a message + + MimeMessage msg = new MimeMessage(session); + msg.setFrom( new InternetAddress("no-reply@daoas.dk") ); + + msg.setRecipient(Message.RecipientType.TO, new InternetAddress(loader.config.notifyEmail) ); + msg.setSubject("DaoAdresseService status "); + msg.setText("--"); + + Transport.send(msg); + } catch (Exception e) { + logger.warning("Unable to send CircuitBreaker notification mail " + e ); + } + } + }