1 |
torben |
421 |
package dk.thoerup.traininfoservice; |
2 |
|
|
|
3 |
|
|
import java.util.logging.Logger; |
4 |
|
|
|
5 |
|
|
import javax.servlet.ServletContextEvent; |
6 |
|
|
import javax.servlet.ServletContextListener; |
7 |
torben |
1308 |
import javax.servlet.ServletRegistration; |
8 |
torben |
959 |
import javax.servlet.annotation.WebListener; |
9 |
torben |
421 |
|
10 |
torben |
468 |
import dk.thoerup.circuitbreaker.AccountingCircuitBreaker; |
11 |
torben |
1308 |
import dk.thoerup.circuitbreaker.CircuitBreakerManager; |
12 |
torben |
1286 |
import dk.thoerup.circuitbreaker.LoggingCircuitBreaker; |
13 |
torben |
1308 |
import dk.thoerup.circuitbreaker.notification.CompositeNotifier; |
14 |
|
|
import dk.thoerup.circuitbreaker.notification.JavaLogNotifier; |
15 |
|
|
import dk.thoerup.circuitbreaker.notification.MailNotifier; |
16 |
torben |
421 |
|
17 |
torben |
1156 |
|
18 |
torben |
421 |
/** |
19 |
|
|
* Application Lifecycle Listener implementation class JmxListener |
20 |
|
|
* |
21 |
|
|
*/ |
22 |
torben |
959 |
@WebListener |
23 |
torben |
421 |
public class CircuitBreakerListener implements ServletContextListener { |
24 |
|
|
|
25 |
|
|
Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName()); |
26 |
|
|
|
27 |
|
|
public CircuitBreakerListener() { |
28 |
|
|
} |
29 |
|
|
|
30 |
|
|
/** |
31 |
|
|
* @see ServletContextListener#contextInitialized(ServletContextEvent) |
32 |
|
|
*/ |
33 |
|
|
public void contextInitialized(ServletContextEvent sce) { |
34 |
|
|
logger.warning("Context Init"); |
35 |
|
|
|
36 |
torben |
1316 |
TraininfoSettings settings = SettingsListener.loadSettings( sce.getServletContext() ); |
37 |
|
|
|
38 |
torben |
421 |
CircuitBreakerManager mgr = CircuitBreakerManager.getManager(); |
39 |
|
|
|
40 |
torben |
1162 |
CompositeNotifier notif = new CompositeNotifier(); |
41 |
|
|
notif.addNotifier( new JavaLogNotifier() ); |
42 |
|
|
notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") ); |
43 |
|
|
|
44 |
torben |
1156 |
|
45 |
torben |
1316 |
LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", settings); |
46 |
torben |
1156 |
banedk.setNotifier(notif); |
47 |
torben |
1042 |
mgr.addCircuitBreaker( banedk ); |
48 |
torben |
421 |
|
49 |
torben |
1162 |
|
50 |
torben |
1316 |
AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", settings); |
51 |
torben |
1162 |
metro.setNotifier(notif); |
52 |
torben |
1042 |
mgr.addCircuitBreaker( metro ); |
53 |
|
|
|
54 |
torben |
1308 |
|
55 |
|
|
ServletRegistration.Dynamic dynconf = sce.getServletContext().addServlet("circuitbreaker", dk.thoerup.circuitbreaker.web.CircuitBreakerServletBase.class ); |
56 |
|
|
dynconf.addMapping("/CircuitBreakerServlet"); |
57 |
|
|
dynconf.setInitParameter("readonly", "0"); |
58 |
|
|
|
59 |
torben |
1304 |
//JMXWrapper.registerAllCircuitBreakers(); |
60 |
torben |
421 |
} |
61 |
|
|
|
62 |
|
|
/** |
63 |
|
|
* @see ServletContextListener#contextDestroyed(ServletContextEvent) |
64 |
|
|
*/ |
65 |
|
|
public void contextDestroyed(ServletContextEvent sce) { |
66 |
|
|
logger.warning("Context Destroyed"); |
67 |
torben |
1156 |
CircuitBreakerManager.getManager().shutdown(); |
68 |
torben |
866 |
|
69 |
torben |
1304 |
//JMXWrapper.unregisterAllCircuitBreakers(); |
70 |
torben |
421 |
} |
71 |
|
|
|
72 |
|
|
} |