/[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 1156 by torben, Sun Oct 3 17:23:13 2010 UTC revision 1304 by torben, Tue Apr 19 12:44:01 2011 UTC
# Line 7  import javax.servlet.ServletContextListe Line 7  import javax.servlet.ServletContextListe
7  import javax.servlet.annotation.WebListener;  import javax.servlet.annotation.WebListener;
8    
9  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;  import dk.thoerup.circuitbreaker.AccountingCircuitBreaker;
10    import dk.thoerup.circuitbreaker.LoggingCircuitBreaker;
11  import dk.thoerup.circuitbreaker.CircuitBreakerManager;  import dk.thoerup.circuitbreaker.CircuitBreakerManager;
12  import dk.thoerup.circuitbreaker.jmx.JMXWrapper;  import dk.thoerup.circuitbreaker.jmx.JMXWrapper;
13  import dk.thoerup.circuitbreaker.notification.*;  import dk.thoerup.circuitbreaker.notification.*;
# Line 34  public class CircuitBreakerListener impl Line 35  public class CircuitBreakerListener impl
35          int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );          int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") );
36          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();          CircuitBreakerManager mgr = CircuitBreakerManager.getManager();
37                    
           
                 AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout);  
38                  CompositeNotifier notif = new CompositeNotifier();                  CompositeNotifier notif = new CompositeNotifier();
39                  notif.addNotifier( new JavaLogNotifier() );                  notif.addNotifier( new JavaLogNotifier() );
40                  notif.addNotifier( new MailNotifier(banedk,"traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );                  notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );
41                    
42            
43                    LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", threshold, timeout);
44                  banedk.setNotifier(notif);                  banedk.setNotifier(notif);
45                  mgr.addCircuitBreaker( banedk );                  mgr.addCircuitBreaker( banedk );
46                                    
47                    
48                  AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);                  AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout);
49                  notif = new CompositeNotifier();                  metro.setNotifier(notif);
                 notif.addNotifier( new JavaLogNotifier() );  
                 notif.addNotifier( new MailNotifier(banedk,"traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") );  
                 banedk.setNotifier(notif);  
50                  mgr.addCircuitBreaker( metro );                  mgr.addCircuitBreaker( metro );
51                                    
52                  JMXWrapper.registerAllCircuitBreakers();                  //JMXWrapper.registerAllCircuitBreakers();
53      }      }
54    
55          /**          /**
# Line 59  public class CircuitBreakerListener impl Line 59  public class CircuitBreakerListener impl
59          logger.warning("Context Destroyed");          logger.warning("Context Destroyed");
60          CircuitBreakerManager.getManager().shutdown();          CircuitBreakerManager.getManager().shutdown();
61    
62          JMXWrapper.unregisterAllCircuitBreakers();          //JMXWrapper.unregisterAllCircuitBreakers();
63      }      }
64                    
65  }  }
Legend:
Removed from v.1156  
changed lines
  Added in v.1304
  ViewVC Help
Powered by ViewVC 1.1.20