--- android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java 2009/10/20 20:44:12 457 +++ android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java 2010/07/05 09:49:53 959 @@ -4,16 +4,18 @@ import javax.servlet.ServletContextEvent; import javax.servlet.ServletContextListener; +import javax.servlet.annotation.WebListener; -import dk.thoerup.curcuitbreaker.AccountingCircuitBreaker; -import dk.thoerup.curcuitbreaker.CircuitBreakerManager; -import dk.thoerup.curcuitbreaker.jmx.JMXWrapper; -import dk.thoerup.curcuitbreaker.notification.JavaLogNotifier; +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 * */ +@WebListener public class CircuitBreakerListener implements ServletContextListener { Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName()); @@ -27,9 +29,11 @@ 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", 5, 30000); + AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout); banedk.setNotifier( new JavaLogNotifier() ); mgr.addCircuitBreaker( banedk ); @@ -41,6 +45,8 @@ */ public void contextDestroyed(ServletContextEvent sce) { logger.warning("Context Destroyed"); + CircuitBreakerManager.getManager().removeCircuitBreaker("banedk"); + JMXWrapper.unregisterAllCircuitBreakers(); }