/[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 425 by torben, Thu Oct 8 20:46:40 2009 UTC revision 1162 by torben, Mon Oct 4 17:38:13 2010 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.annotation.WebListener;
8    
9    import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
10    import dk.thoerup.circuitbreaker.CircuitBreakerManager;
11    import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
12    import dk.thoerup.circuitbreaker.notification.*;
13    
 import dk.thoerup.curcuitbreaker.AccountingCircuitBreaker;  
 import dk.thoerup.curcuitbreaker.CircuitBreakerManager;  
 import dk.thoerup.curcuitbreaker.jmx.JMXWrapper;  
 import dk.thoerup.curcuitbreaker.notification.JavaLogNotifier;  
14    
15  /**  /**
16   * Application Lifecycle Listener implementation class JmxListener   * Application Lifecycle Listener implementation class JmxListener
17   *   *
18   */   */
19    @WebListener
20  public class CircuitBreakerListener implements ServletContextListener {  public class CircuitBreakerListener implements ServletContextListener {
21    
22          Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());          Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());
# Line 27  public class CircuitBreakerListener impl Line 30  public class CircuitBreakerListener impl
30      public void contextInitialized(ServletContextEvent sce) {      public void contextInitialized(ServletContextEvent sce) {
31          logger.warning("Context Init");          logger.warning("Context Init");
32                    
33            int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") );
34            int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );
35          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
36                    
37                  AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", 5, 20000);                  CompositeNotifier notif = new CompositeNotifier();
38                  banedk.setNotifier( new JavaLogNotifier() );                  notif.addNotifier( new JavaLogNotifier() );
39                  mgr.addCircuitBreaker( banedk );                                  notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
40                    
41            
42                    AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout);
43                    banedk.setNotifier(notif);
44                    mgr.addCircuitBreaker( banedk );
45                    
46                    
47                    AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);
48                    metro.setNotifier(notif);
49                    mgr.addCircuitBreaker( metro );
50                                    
51                  JMXWrapper.registerAllCircuitBreakers();                  JMXWrapper.registerAllCircuitBreakers();
52      }      }
# Line 41  public class CircuitBreakerListener impl Line 56  public class CircuitBreakerListener impl
56       */       */
57      public void contextDestroyed(ServletContextEvent sce) {      public void contextDestroyed(ServletContextEvent sce) {
58          logger.warning("Context Destroyed");          logger.warning("Context Destroyed");
59            CircuitBreakerManager.getManager().shutdown();
60    
61          JMXWrapper.unregisterAllCircuitBreakers();          JMXWrapper.unregisterAllCircuitBreakers();
62      }      }
63                    
Legend:
Removed from v.425  
changed lines
  Added in v.1162
  ViewVC Help
Powered by ViewVC 1.1.20