thoerup/traininfoservice/CircuitBreakerListener.java

package dk.thoerup.traininfoservice;

import java.util.logging.Logger;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.ServletRegistration;
import javax.servlet.annotation.WebListener;

import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
import dk.thoerup.circuitbreaker.CircuitBreakerManager;
import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
import dk.thoerup.circuitbreaker.notification.CompositeNotifier;
import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;
import dk.thoerup.circuitbreaker.notification.MailNotifier;


/**
 * Application Lifecycle Listener implementation class JmxListener
 *
 */
@WebListener
public class CircuitBreakerListener implements ServletContextListener {

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

    public CircuitBreakerListener() {
    }

        /**
     * @see ServletContextListener#contextInitialized(ServletContextEvent)
     */
    public void contextInitialized(ServletContextEvent sce) {
        logger.warning("Context Init");
        
        TraininfoSettings settings = SettingsListener.loadSettings( sce.getServletContext() );

        CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
        
                CompositeNotifier notif = new CompositeNotifier();
                notif.addNotifier( new JavaLogNotifier() );
                 
                //only send mail on prod server
                if (sce.getServletContext().getRealPath("/").startsWith("/home/app/")  ) {              
                        notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
        }
        
                LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", settings);
                banedk.setNotifier(notif);
                mgr.addCircuitBreaker( banedk );
                
                
                AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", settings);
                metro.setNotifier(notif);
                mgr.addCircuitBreaker( metro );
                
                
                ServletRegistration.Dynamic dynconf = sce.getServletContext().addServlet("circuitbreaker", dk.thoerup.circuitbreaker.web.CircuitBreakerServletBase.class );
                dynconf.addMapping("/CircuitBreakerServlet");
                dynconf.setInitParameter("readonly", "0");
                
                //JMXWrapper.registerAllCircuitBreakers();
    }

        /**
     * @see ServletContextListener#contextDestroyed(ServletContextEvent)
     */
    public void contextDestroyed(ServletContextEvent sce) {
        logger.warning("Context Destroyed");
        CircuitBreakerManager.getManager().shutdown(); 

        //JMXWrapper.unregisterAllCircuitBreakers();
    }
        
}
1	package dk.thoerup.traininfoservice;
2
3	import java.util.logging.Logger;
4
5	import javax.servlet.ServletContextEvent;
6	import javax.servlet.ServletContextListener;
7	import javax.servlet.ServletRegistration;
8	import javax.servlet.annotation.WebListener;
9
10	import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
11	import dk.thoerup.circuitbreaker.CircuitBreakerManager;
12	import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
13	import dk.thoerup.circuitbreaker.notification.CompositeNotifier;
14	import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;
15	import dk.thoerup.circuitbreaker.notification.MailNotifier;
16
17
18	/**
19	* Application Lifecycle Listener implementation class JmxListener
20	*
21	*/
22	@WebListener
23	public class CircuitBreakerListener implements ServletContextListener {
24
25	Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());
26
27	public CircuitBreakerListener() {
28	}
29
30	/**
31	* @see ServletContextListener#contextInitialized(ServletContextEvent)
32	*/
33	public void contextInitialized(ServletContextEvent sce) {
34	logger.warning("Context Init");
35
36	TraininfoSettings settings = SettingsListener.loadSettings( sce.getServletContext() );
37
38	CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
39
40	CompositeNotifier notif = new CompositeNotifier();
41	notif.addNotifier( new JavaLogNotifier() );
42
43	//only send mail on prod server
44	if (sce.getServletContext().getRealPath("/").startsWith("/home/app/") ) {
45	notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
46	}
47
48	LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", settings);
49	banedk.setNotifier(notif);
50	mgr.addCircuitBreaker( banedk );
51
52
53	AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", settings);
54	metro.setNotifier(notif);
55	mgr.addCircuitBreaker( metro );
56
57
58	ServletRegistration.Dynamic dynconf = sce.getServletContext().addServlet("circuitbreaker", dk.thoerup.circuitbreaker.web.CircuitBreakerServletBase.class );
59	dynconf.addMapping("/CircuitBreakerServlet");
60	dynconf.setInitParameter("readonly", "0");
61
62	//JMXWrapper.registerAllCircuitBreakers();
63	}
64
65	/**
66	* @see ServletContextListener#contextDestroyed(ServletContextEvent)
67	*/
68	public void contextDestroyed(ServletContextEvent sce) {
69	logger.warning("Context Destroyed");
70	CircuitBreakerManager.getManager().shutdown();
71
72	//JMXWrapper.unregisterAllCircuitBreakers();
73	}
74
75	}