thoerup/traininfoservice/CircuitBreakerListener.java

package dk.thoerup.traininfoservice;

import java.util.logging.Logger;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
import dk.thoerup.circuitbreaker.CircuitBreakerManager;
import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;

/**
 * Application Lifecycle Listener implementation class JmxListener
 *
 */

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);
                banedk.setNotifier( new JavaLogNotifier() );
                mgr.addCircuitBreaker( banedk );
                
                AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);
                metro.setNotifier( new JavaLogNotifier() );
                mgr.addCircuitBreaker( metro );
                
                //JMXWrapper.registerAllCircuitBreakers();
    }

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

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