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