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 |
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 |
mgr.addCircuitBreaker( banedk ); |
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 ); |
44 |
|
|
45 |
|
AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout); |
46 |
|
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 ); |
51 |
|
|
52 |
JMXWrapper.registerAllCircuitBreakers(); |
JMXWrapper.registerAllCircuitBreakers(); |
53 |
} |
} |
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 |
} |
} |