thoerup/traininfoservice/CircuitBreakerListener.java

package dk.thoerup.traininfoservice;

import java.util.logging.Logger;

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

import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
import dk.thoerup.circuitbreaker.CircuitBreakerManager;
import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
import dk.thoerup.circuitbreaker.notification.*;


/**
 * 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");
        
        int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") );
        int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );
        CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
        
                CompositeNotifier notif = new CompositeNotifier();
                notif.addNotifier( new JavaLogNotifier() );
                notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
                
        
                LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", threshold, timeout);
                banedk.setNotifier(notif);
                mgr.addCircuitBreaker( banedk );
                
                
                AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);
                metro.setNotifier(notif);
                mgr.addCircuitBreaker( metro );
                
                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.annotation.WebListener;
8
9	import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
10	import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
11	import dk.thoerup.circuitbreaker.CircuitBreakerManager;
12	import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
13	import dk.thoerup.circuitbreaker.notification.*;
14
15
16	/**
17	* Application Lifecycle Listener implementation class JmxListener
18	*
19	*/
20	@WebListener
21	public class CircuitBreakerListener implements ServletContextListener {
22
23	Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());
24
25	public CircuitBreakerListener() {
26	}
27
28	/**
29	* @see ServletContextListener#contextInitialized(ServletContextEvent)
30	*/
31	public void contextInitialized(ServletContextEvent sce) {
32	logger.warning("Context Init");
33
34	int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") );
35	int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );
36	CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
37
38	CompositeNotifier notif = new CompositeNotifier();
39	notif.addNotifier( new JavaLogNotifier() );
40	notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
41
42
43	LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", threshold, timeout);
44	banedk.setNotifier(notif);
45	mgr.addCircuitBreaker( banedk );
46
47
48	AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);
49	metro.setNotifier(notif);
50	mgr.addCircuitBreaker( metro );
51
52	JMXWrapper.registerAllCircuitBreakers();
53	}
54
55	/**
56	* @see ServletContextListener#contextDestroyed(ServletContextEvent)
57	*/
58	public void contextDestroyed(ServletContextEvent sce) {
59	logger.warning("Context Destroyed");
60	CircuitBreakerManager.getManager().shutdown();
61
62	JMXWrapper.unregisterAllCircuitBreakers();
63	}
64
65	}