--- android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java	2009/10/08 12:19:42	421
+++ android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java	2011/04/11 07:53:45	1286
@@ -4,17 +4,20 @@
 
 import javax.servlet.ServletContextEvent;
 import javax.servlet.ServletContextListener;
+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.*;
 
-import dk.thoerup.curcuitbreaker.AccountingCircuitBreaker;
-import dk.thoerup.curcuitbreaker.CircuitBreaker;
-import dk.thoerup.curcuitbreaker.CircuitBreakerManager;
-import dk.thoerup.curcuitbreaker.jmx.JMXWrapper;
-import dk.thoerup.curcuitbreaker.notification.JavaLogNotifier;
 
 /**
  * Application Lifecycle Listener implementation class JmxListener
  *
  */
+@WebListener
 public class CircuitBreakerListener implements ServletContextListener {
 
 	Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());
@@ -28,11 +31,23 @@
     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, 20000);
-		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();
     }
@@ -42,6 +57,8 @@
      */
     public void contextDestroyed(ServletContextEvent sce) {
     	logger.warning("Context Destroyed");
+    	CircuitBreakerManager.getManager().shutdown(); 
+
     	JMXWrapper.unregisterAllCircuitBreakers();
     }