4 |
|
|
5 |
import javax.servlet.ServletContextEvent; |
import javax.servlet.ServletContextEvent; |
6 |
import javax.servlet.ServletContextListener; |
import javax.servlet.ServletContextListener; |
7 |
|
import javax.servlet.annotation.WebListener; |
8 |
|
|
9 |
import dk.thoerup.curcuitbreaker.AccountingCircuitBreaker; |
import dk.thoerup.circuitbreaker.AccountingCircuitBreaker; |
10 |
import dk.thoerup.curcuitbreaker.CircuitBreakerManager; |
import dk.thoerup.circuitbreaker.CircuitBreakerManager; |
11 |
import dk.thoerup.curcuitbreaker.jmx.JMXWrapper; |
import dk.thoerup.circuitbreaker.jmx.JMXWrapper; |
12 |
import dk.thoerup.curcuitbreaker.notification.JavaLogNotifier; |
import dk.thoerup.circuitbreaker.notification.JavaLogNotifier; |
13 |
|
|
14 |
/** |
/** |
15 |
* Application Lifecycle Listener implementation class JmxListener |
* Application Lifecycle Listener implementation class JmxListener |
16 |
* |
* |
17 |
*/ |
*/ |
18 |
|
@WebListener |
19 |
public class CircuitBreakerListener implements ServletContextListener { |
public class CircuitBreakerListener implements ServletContextListener { |
20 |
|
|
21 |
Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName()); |
Logger logger = Logger.getLogger(CircuitBreakerListener.class.getName()); |
29 |
public void contextInitialized(ServletContextEvent sce) { |
public void contextInitialized(ServletContextEvent sce) { |
30 |
logger.warning("Context Init"); |
logger.warning("Context Init"); |
31 |
|
|
32 |
|
int threshold = Integer.parseInt(sce.getServletContext().getInitParameter("banedk_threshold") ); |
33 |
|
int timeout = Integer.parseInt( sce.getServletContext().getInitParameter("banedk_timeout") ); |
34 |
CircuitBreakerManager mgr = CircuitBreakerManager.getManager(); |
CircuitBreakerManager mgr = CircuitBreakerManager.getManager(); |
35 |
|
|
36 |
AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", 5, 20000); |
AccountingCircuitBreaker banedk = new AccountingCircuitBreaker("banedk", threshold, timeout); |
37 |
banedk.setNotifier( new JavaLogNotifier() ); |
banedk.setNotifier( new JavaLogNotifier() ); |
38 |
mgr.addCircuitBreaker( banedk ); |
mgr.addCircuitBreaker( banedk ); |
39 |
|
|
40 |
|
AccountingCircuitBreaker metro = new AccountingCircuitBreaker("metro", threshold, timeout); |
41 |
|
metro.setNotifier( new JavaLogNotifier() ); |
42 |
|
mgr.addCircuitBreaker( metro ); |
43 |
|
|
44 |
JMXWrapper.registerAllCircuitBreakers(); |
JMXWrapper.registerAllCircuitBreakers(); |
45 |
} |
} |
49 |
*/ |
*/ |
50 |
public void contextDestroyed(ServletContextEvent sce) { |
public void contextDestroyed(ServletContextEvent sce) { |
51 |
logger.warning("Context Destroyed"); |
logger.warning("Context Destroyed"); |
52 |
|
CircuitBreakerManager.getManager().removeCircuitBreaker("banedk"); |
53 |
|
|
54 |
JMXWrapper.unregisterAllCircuitBreakers(); |
JMXWrapper.unregisterAllCircuitBreakers(); |
55 |
} |
} |
56 |
|
|