--- dao/DaoAdresseService/src/dk/daoas/daoadresseservice/ContextListener.java 2015/02/13 15:47:48 2284 +++ dao/DaoAdresseService/src/dk/daoas/daoadresseservice/ContextListener.java 2015/02/23 15:49:00 2352 @@ -1,12 +1,18 @@ package dk.daoas.daoadresseservice; -import java.sql.SQLException; - import javax.servlet.ServletContext; import javax.servlet.ServletContextEvent; import javax.servlet.ServletContextListener; +import javax.servlet.ServletRegistration; import javax.servlet.annotation.WebListener; +import dk.daoas.daoadresseservice.admin.ServiceConfig; +import dk.thoerup.circuitbreaker.AccountingCircuitBreaker; +import dk.thoerup.circuitbreaker.CircuitBreakerManager; +import dk.thoerup.circuitbreaker.web.CircuitBreakerServletBase; +import dk.thoerup.webconfig.ConfigServlet; +import dk.thoerup.webconfig.ContextConfigLoader; + /** * Application Lifecycle Listener implementation class ContextListener * @@ -14,27 +20,7 @@ @WebListener public class ContextListener implements ServletContextListener { - public static class DataLoader implements Runnable { - ServletContext ctxt; - public DataLoader(ServletContext ctxt) { - this.ctxt = ctxt; - } - - - @Override - public void run() { - - AdressSearch search = new AdressSearch(); - try { - search.buildSearchStructures(); - ctxt.setAttribute("search", search); - } catch (SQLException e) { - System.out.println("Error loading data: " + e.getMessage()); - } - } - - } public ContextListener() { @@ -45,15 +31,63 @@ // TODO Auto-generated method stub } + @Override public void contextInitialized(ServletContextEvent ctxtEvt) { System.out.println("Starting DAO Context"); ServletContext ctxt = ctxtEvt.getServletContext(); - Thread t = new Thread( new DataLoader(ctxt), "SearchDataLoader"); - t.start(); + ServiceConfig conf = initConfig(ctxt); + + initDataLoader(ctxt, conf); + + initCircuitBreakers(ctxt, conf); + System.out.println("DAO Context done"); } + + private void initDataLoader(ServletContext ctxt, ServiceConfig conf) { + DataLoader load = new DataLoader(ctxt,conf); + ctxt.setAttribute("dataloader", load); + load.doLoad(); + } + + + private ServiceConfig initConfig(ServletContext ctxt) { + ServiceConfig conf = new ServiceConfig(); + + new ContextConfigLoader(ctxt).loadConfig(conf); + + ctxt.setAttribute("config", conf); + + // ///////////////////////////////////// + ConfigServlet servlet = new ConfigServlet(); + servlet.setConfigObject( conf ); + ServletRegistration.Dynamic dynconf = ctxt.addServlet("webconfig", servlet ); + dynconf.addMapping("/ConfigServlet"); + + return conf; + + } + + private void initCircuitBreakers(ServletContext ctxt, ServiceConfig conf) { + CircuitBreakerManager mgr = CircuitBreakerManager.getManager(); + + AccountingCircuitBreaker osm = new AccountingCircuitBreaker("osm", conf); + mgr.addCircuitBreaker( osm ); + + AccountingCircuitBreaker google = new AccountingCircuitBreaker("google", conf); + mgr.addCircuitBreaker( google ); + + + // + CircuitBreakerServletBase servlet = new CircuitBreakerServletBase(); + ServletRegistration.Dynamic dynconf = ctxt.addServlet("circuitbreaker", servlet); + dynconf.addMapping("/CircuitBreakerServlet"); + dynconf.setInitParameter("readonly", "1"); + + } + }