/[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 1155 by torben, Mon Sep 13 17:57:31 2010 UTC revision 1156 by torben, Sun Oct 3 17:23:13 2010 UTC
# Line 9  import javax.servlet.annotation.WebListe Line 9  import javax.servlet.annotation.WebListe
9  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
10  import dk.thoerup.circuitbreaker.CircuitBreakerManager;  import dk.thoerup.circuitbreaker.CircuitBreakerManager;
11  import dk.thoerup.circuitbreaker.jmx.JMXWrapper;  import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
12  import dk.thoerup.circuitbreaker.notification.JavaLogNotifier;  import dk.thoerup.circuitbreaker.notification.*;
13    
14    
15  /**  /**
16   * Application Lifecycle Listener implementation class JmxListener   * Application Lifecycle Listener implementation class JmxListener
# Line 33  public class CircuitBreakerListener impl Line 34  public class CircuitBreakerListener impl
34          int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );          int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );
35          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
36                    
37            
38                  AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout);                  AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout);
39                  banedk.setNotifier( new JavaLogNotifier() );                  CompositeNotifier notif = new CompositeNotifier();
40                    notif.addNotifier( new JavaLogNotifier() );
41                    notif.addNotifier( new MailNotifier(banedk,"traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
42                    banedk.setNotifier(notif);
43                  mgr.addCircuitBreaker( banedk );                  mgr.addCircuitBreaker( banedk );
44                                    
45                  AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);                  AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);
46                  metro.setNotifier( new JavaLogNotifier() );                  notif = new CompositeNotifier();
47                    notif.addNotifier( new JavaLogNotifier() );
48                    notif.addNotifier( new MailNotifier(banedk,"traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
49                    banedk.setNotifier(notif);
50                  mgr.addCircuitBreaker( metro );                  mgr.addCircuitBreaker( metro );
51                                    
52                  JMXWrapper.registerAllCircuitBreakers();                  JMXWrapper.registerAllCircuitBreakers();
# Line 49  public class CircuitBreakerListener impl Line 57  public class CircuitBreakerListener impl
57       */       */
58      public void contextDestroyed(ServletContextEvent sce) {      public void contextDestroyed(ServletContextEvent sce) {
59          logger.warning("Context Destroyed");          logger.warning("Context Destroyed");
60                  CircuitBreakerManager.getManager().removeCircuitBreaker("banedk");          CircuitBreakerManager.getManager().shutdown();
61    
62          JMXWrapper.unregisterAllCircuitBreakers();          JMXWrapper.unregisterAllCircuitBreakers();
63      }      }
Legend:
Removed from v.1155  
changed lines
  Added in v.1156
  ViewVC Help
Powered by ViewVC 1.1.20