/[projects]/miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/notification/MailNotifier.java
ViewVC logotype

Diff of /miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/notification/MailNotifier.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1149 by torben, Fri Oct 1 12:57:06 2010 UTC revision 1155 by torben, Sun Oct 3 17:17:38 2010 UTC
# Line 32  public class MailNotifier extends AsyncN Line 32  public class MailNotifier extends AsyncN
32                  props.put("mail.smtp.host", mailhost);                  props.put("mail.smtp.host", mailhost);
33          }          }
34    
35          //TODO: Only send mail when event == trigger || event == reset  
36          @Override          @Override
37          public void sendAsync(String breakerName, Event evnt) {          public void sendAsync(String breakerName, Event evnt) {
38                  try {                  try {
39                            if (evnt == Event.BreakerTripped || evnt == Event.BreakerReset) {
40                          // create some properties and get the default Session                                  // create some properties and get the default Session
41                          Session session = Session.getDefaultInstance(props, null);                                  Session session = Session.getDefaultInstance(props, null);
42                          session.setDebug(true);                                  session.setDebug(true);
43                                                            
44                                                            
45                          // create a message                                  // create a message
46                                                            
47                          MimeMessage msg = new MimeMessage(session);                                  MimeMessage msg = new MimeMessage(session);
48                          msg.setFrom( new InternetAddress(from) );                                  msg.setFrom( new InternetAddress(from) );
49                                                            
50                          msg.setRecipient(Message.RecipientType.TO, new InternetAddress(recipient) );                                  msg.setRecipient(Message.RecipientType.TO, new InternetAddress(recipient) );
51                          msg.setSubject("Circuitbreaker " + breakerName + " : " + evnt.toString());                                                        msg.setSubject("Circuitbreaker " + breakerName + " : " + evnt.toString());                      
52                          msg.setText("--");                                  msg.setText("--");
53                                                            
54                          Transport.send(msg);                                  Transport.send(msg);
55                            }
56                  } catch (Exception e) {                  } catch (Exception e) {
57                          logger.warning("Unable to send CircuitBreaker notification mail " + e );                          logger.warning("Unable to send CircuitBreaker notification mail " + e );
58                  }                  }
Legend:
Removed from v.1149  
changed lines
  Added in v.1155
  ViewVC Help
Powered by ViewVC 1.1.20