4 |
|
|
5 |
import javax.servlet.ServletContextEvent; |
import javax.servlet.ServletContextEvent; |
6 |
import javax.servlet.ServletContextListener; |
import javax.servlet.ServletContextListener; |
7 |
|
import javax.servlet.ServletRegistration; |
8 |
import javax.servlet.annotation.WebListener; |
import javax.servlet.annotation.WebListener; |
9 |
|
|
10 |
import dk.thoerup.circuitbreaker.AccountingCircuitBreaker; |
import dk.thoerup.circuitbreaker.AccountingCircuitBreaker; |
|
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.LoggingCircuitBreaker; |
13 |
import dk.thoerup.circuitbreaker.notification.*; |
import dk.thoerup.circuitbreaker.notification.CompositeNotifier; |
14 |
|
import dk.thoerup.circuitbreaker.notification.JavaLogNotifier; |
15 |
|
import dk.thoerup.circuitbreaker.notification.MailNotifier; |
16 |
|
|
17 |
|
|
18 |
/** |
/** |
33 |
public void contextInitialized(ServletContextEvent sce) { |
public void contextInitialized(ServletContextEvent sce) { |
34 |
logger.warning("Context Init"); |
logger.warning("Context Init"); |
35 |
|
|
36 |
int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") ); |
TraininfoSettings settings = SettingsListener.loadSettings( sce.getServletContext() ); |
37 |
int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") ); |
|
38 |
CircuitBreakerManager mgr = CircuitBreakerManager.getManager(); |
CircuitBreakerManager mgr = CircuitBreakerManager.getManager(); |
39 |
|
|
40 |
CompositeNotifier notif = new CompositeNotifier(); |
CompositeNotifier notif = new CompositeNotifier(); |
41 |
notif.addNotifier( new JavaLogNotifier() ); |
notif.addNotifier( new JavaLogNotifier() ); |
42 |
notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") ); |
|
43 |
|
//only send mail on prod server |
44 |
|
if (sce.getServletContext().getRealPath("/").startsWith("/home/app/") ) { |
45 |
|
notif.addNotifier( new MailNotifier("traininfo@t-hoerup.dk", "torben@t-hoerup.dk", "192.168.10.5") ); |
46 |
|
} |
47 |
|
|
48 |
LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", threshold, timeout); |
LoggingCircuitBreaker banedk = new LoggingCircuitBreaker("banedk", settings); |
49 |
banedk.setNotifier(notif); |
banedk.setNotifier(notif); |
50 |
mgr.addCircuitBreaker( banedk ); |
mgr.addCircuitBreaker( banedk ); |
51 |
|
|
52 |
|
|
53 |
AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout); |
AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", settings); |
54 |
metro.setNotifier(notif); |
metro.setNotifier(notif); |
55 |
mgr.addCircuitBreaker( metro ); |
mgr.addCircuitBreaker( metro ); |
56 |
|
|
57 |
|
|
58 |
|
ServletRegistration.Dynamic dynconf = sce.getServletContext().addServlet("circuitbreaker", dk.thoerup.circuitbreaker.web.CircuitBreakerServletBase.class ); |
59 |
|
dynconf.addMapping("/CircuitBreakerServlet"); |
60 |
|
dynconf.setInitParameter("readonly", "0"); |
61 |
|
|
62 |
//JMXWrapper.registerAllCircuitBreakers(); |
//JMXWrapper.registerAllCircuitBreakers(); |
63 |
} |
} |
64 |
|
|