--- android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java 2010/06/20 22:10:29 866 +++ android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java 2010/10/04 17:38:13 1162 @@ -4,16 +4,19 @@ 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.JavaLogNotifier; +import dk.thoerup.circuitbreaker.notification.*; + /** * Application Lifecycle Listener implementation class JmxListener * */ +@WebListener public class CircuitBreakerListener implements ServletContextListener { Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName()); @@ -31,9 +34,19 @@ 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") ); + + AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout); - banedk.setNotifier( new JavaLogNotifier() ); - mgr.addCircuitBreaker( banedk ); + banedk.setNotifier(notif); + mgr.addCircuitBreaker( banedk ); + + + AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout); + metro.setNotifier(notif); + mgr.addCircuitBreaker( metro ); JMXWrapper.registerAllCircuitBreakers(); } @@ -43,7 +56,7 @@ */ public void contextDestroyed(ServletContextEvent sce) { logger.warning("Context Destroyed"); - CircuitBreakerManager.getManager().removeCircuitBreaker("banedk"); + CircuitBreakerManager.getManager().shutdown(); JMXWrapper.unregisterAllCircuitBreakers(); }