/[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 421 by torben, Thu Oct 8 12:19:42 2009 UTC revision 959 by torben, Mon Jul 5 09:49:53 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.curcuitbreaker.AccountingCircuitBreaker;  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
10  import dk.thoerup.curcuitbreaker.CircuitBreaker;  import dk.thoerup.circuitbreaker.CircuitBreakerManager;
11  import dk.thoerup.curcuitbreaker.CircuitBreakerManager;  import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
12  import dk.thoerup.curcuitbreaker.jmx.JMXWrapper;  import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;
 import dk.thoerup.curcuitbreaker.notification.JavaLogNotifier;  
13    
14  /**  /**
15   * Application Lifecycle Listener implementation class JmxListener   * Application Lifecycle Listener implementation class JmxListener
16   *   *
17   */   */
18    @WebListener
19  public class CircuitBreakerListener implements ServletContextListener {  public class CircuitBreakerListener implements ServletContextListener {
20    
21          Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());          Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName());
# Line 28  public class CircuitBreakerListener impl Line 29  public class CircuitBreakerListener impl
29      public void contextInitialized(ServletContextEvent sce) {      public void contextInitialized(ServletContextEvent sce) {
30          logger.warning("Context Init");          logger.warning("Context Init");
31                    
32            int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") );
33            int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );
34          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
35                    
36                  AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", 5, 20000);                  AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout);
37                  banedk.setNotifier( new JavaLogNotifier() );                  banedk.setNotifier( new JavaLogNotifier() );
38                  mgr.addCircuitBreaker( banedk );                                  mgr.addCircuitBreaker( banedk );                
39                                    
# Line 42  public class CircuitBreakerListener impl Line 45  public class CircuitBreakerListener impl
45       */       */
46      public void contextDestroyed(ServletContextEvent sce) {      public void contextDestroyed(ServletContextEvent sce) {
47          logger.warning("Context Destroyed");          logger.warning("Context Destroyed");
48                    CircuitBreakerManager.getManager().removeCircuitBreaker("banedk");
49    
50          JMXWrapper.unregisterAllCircuitBreakers();          JMXWrapper.unregisterAllCircuitBreakers();
51      }      }
52                    
Legend:
Removed from v.421  
changed lines
  Added in v.959
  ViewVC Help
Powered by ViewVC 1.1.20