/[projects]/android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java
ViewVC logotype

Diff of /android/TrainInfoService/src/dk/thoerup/traininfoservice/CircuitBreakerListener.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1042 by torben, Mon Sep 13 17:57:31 2010 UTC revision 1316 by torben, Tue Apr 19 17:17:09 2011 UTC
# Line 4  import java.util.logging.Logger; Line 4  import java.util.logging.Logger;
4    
5  import javax.servlet.ServletContextEvent;  import javax.servlet.ServletContextEvent;
6  import javax.servlet.ServletContextListener;  import javax.servlet.ServletContextListener;
7    import javax.servlet.ServletRegistration;
8  import javax.servlet.annotation.WebListener;  import javax.servlet.annotation.WebListener;
9    
10  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
11  import dk.thoerup.circuitbreaker.CircuitBreakerManager;  import dk.thoerup.circuitbreaker.CircuitBreakerManager;
12  import dk.thoerup.circuitbreaker.jmx.JMXWrapper;  import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
13    import dk.thoerup.circuitbreaker.notification.CompositeNotifier;
14  import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;  import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;
15    import dk.thoerup.circuitbreaker.notification.MailNotifier;
16    
17    
18  /**  /**
19   * Application Lifecycle Listener implementation class JmxListener   * Application Lifecycle Listener implementation class JmxListener
# Line 29  public class CircuitBreakerListener impl Line 33  public class CircuitBreakerListener impl
33      public void contextInitialized(ServletContextEvent sce) {      public void contextInitialized(ServletContextEvent sce) {
34          logger.warning("Context Init");          logger.warning("Context Init");
35                    
36          int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") );          TraininfoSettings settings = SettingsListener.loadSettings( sce.getServletContext() );
37          int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );  
38          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
39                    
40                  AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout);                  CompositeNotifier notif = new CompositeNotifier();
41                  banedk.setNotifier( new JavaLogNotifier() );                  notif.addNotifier( new JavaLogNotifier() );
42                    notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
43                    
44            
45                    LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", settings);
46                    banedk.setNotifier(notif);
47                  mgr.addCircuitBreaker( banedk );                  mgr.addCircuitBreaker( banedk );
48                                    
49                  AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);                  
50                  metro.setNotifier( new JavaLogNotifier() );                  AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", settings);
51                    metro.setNotifier(notif);
52                  mgr.addCircuitBreaker( metro );                  mgr.addCircuitBreaker( metro );
53                                    
54                  JMXWrapper.registerAllCircuitBreakers();                  
55                    ServletRegistration.Dynamic dynconf = sce.getServletContext().addServlet("circuitbreaker", dk.thoerup.circuitbreaker.web.CircuitBreakerServletBase.class );
56                    dynconf.addMapping("/CircuitBreakerServlet");
57                    dynconf.setInitParameter("readonly", "0");
58                    
59                    //JMXWrapper.registerAllCircuitBreakers();
60      }      }
61    
62          /**          /**
# Line 49  public class CircuitBreakerListener impl Line 64  public class CircuitBreakerListener impl
64       */       */
65      public void contextDestroyed(ServletContextEvent sce) {      public void contextDestroyed(ServletContextEvent sce) {
66          logger.warning("Context Destroyed");          logger.warning("Context Destroyed");
67                  CircuitBreakerManager.getManager().removeCircuitBreaker("banedk");          CircuitBreakerManager.getManager().shutdown();
68    
69          JMXWrapper.unregisterAllCircuitBreakers();          //JMXWrapper.unregisterAllCircuitBreakers();
70      }      }
71                    
72  }  }
Legend:
Removed from v.1042  
changed lines
  Added in v.1316
  ViewVC Help
Powered by ViewVC 1.1.20