--- android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java 2010/07/05 09:49:53 959 +++ android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java 2011/04/19 12:44:01 1304 @@ -7,9 +7,11 @@ 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.JavaLogNotifier; +import dk.thoerup.circuitbreaker.notification.*; + /** * Application Lifecycle Listener implementation class JmxListener @@ -33,11 +35,21 @@ 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 ); + 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(); + //JMXWrapper.registerAllCircuitBreakers(); } /** @@ -45,9 +57,9 @@ */ public void contextDestroyed(ServletContextEvent sce) { logger.warning("Context Destroyed"); - CircuitBreakerManager.getManager().removeCircuitBreaker("banedk"); + CircuitBreakerManager.getManager().shutdown(); - JMXWrapper.unregisterAllCircuitBreakers(); + //JMXWrapper.unregisterAllCircuitBreakers(); } }