circuitbreaker/notification/MailNotifier.java

package dk.thoerup.circuitbreaker.notification;

import java.util.Properties;

import javax.mail.Message;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import java.util.logging.*;

import dk.thoerup.circuitbreaker.CircuitBreaker;

public class MailNotifier extends AsyncNotifier {


        Logger logger = Logger.getLogger(MailNotifier.class.getName());

        private String recipient;
        private String from;
        
        Properties props;

        public MailNotifier(CircuitBreaker cb, String from, String recipient, String mailhost) {
                super(cb);

                this.from = from;
                this.recipient = recipient;
                
                props = new Properties();
                props.put("mail.smtp.host", mailhost);
        }


        @Override
        public void sendAsync(String breakerName, Event evnt) {
                try {
                        if (evnt == Event.BreakerTripped || evnt == Event.BreakerReset) {
                                // create some properties and get the default Session
                                Session session = Session.getDefaultInstance(props, null);
                                session.setDebug(true);
                                
                                
                                // create a message
                                
                                MimeMessage msg = new MimeMessage(session);
                                msg.setFrom( new InternetAddress(from) );
                                
                                msg.setRecipient(Message.RecipientType.TO, new InternetAddress(recipient) );
                                msg.setSubject("Circuitbreaker " + breakerName + " : " + evnt.toString());                      
                                msg.setText("--");
                                
                                Transport.send(msg);
                        }
                } catch (Exception e) {
                        logger.warning("Unable to send CircuitBreaker notification mail " + e );
                }


        }

}
1	package dk.thoerup.circuitbreaker.notification;
2
3	import java.util.Properties;
4
5	import javax.mail.Message;
6	import javax.mail.Session;
7	import javax.mail.Transport;
8	import javax.mail.internet.InternetAddress;
9	import javax.mail.internet.MimeMessage;
10
11	import java.util.logging.*;
12
13	import dk.thoerup.circuitbreaker.CircuitBreaker;
14
15	public class MailNotifier extends AsyncNotifier {
16
17
18	Logger logger = Logger.getLogger(MailNotifier.class.getName());
19
20	private String recipient;
21	private String from;
22
23	Properties props;
24
25	public MailNotifier(CircuitBreaker cb, String from, String recipient, String mailhost) {
26	super(cb);
27
28	this.from = from;
29	this.recipient = recipient;
30
31	props = new Properties();
32	props.put("mail.smtp.host", mailhost);
33	}
34
35
36	@Override
37	public void sendAsync(String breakerName, Event evnt) {
38	try {
39	if (evnt == Event.BreakerTripped \|\| evnt == Event.BreakerReset) {
40	// create some properties and get the default Session
41	Session session = Session.getDefaultInstance(props, null);
42	session.setDebug(true);
43
44
45	// create a message
46
47	MimeMessage msg = new MimeMessage(session);
48	msg.setFrom( new InternetAddress(from) );
49
50	msg.setRecipient(Message.RecipientType.TO, new InternetAddress(recipient) );
51	msg.setSubject("Circuitbreaker " + breakerName + " : " + evnt.toString());
52	msg.setText("--");
53
54	Transport.send(msg);
55	}
56	} catch (Exception e) {
57	logger.warning("Unable to send CircuitBreaker notification mail " + e );
58	}
59
60
61	}
62
63	}