--- android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/DepartureFetcher.java 2009/10/02 15:06:08 387 +++ android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/DepartureFetcher.java 2009/10/08 12:19:42 421 @@ -8,12 +8,13 @@ import java.util.List; import java.util.logging.Logger; - import com.gargoylesoftware.htmlunit.WebClient; import com.gargoylesoftware.htmlunit.html.DomNodeList; import com.gargoylesoftware.htmlunit.html.HtmlElement; import com.gargoylesoftware.htmlunit.html.HtmlPage; +import dk.thoerup.curcuitbreaker.CircuitBreaker; +import dk.thoerup.curcuitbreaker.CircuitBreakerManager; import dk.thoerup.traininfoservice.DBConnection; public class DepartureFetcher { @@ -24,22 +25,21 @@ - public List cachedLookupDepartures(int stationID) throws Exception { + public List cachedLookupDepartures(int stationID) throws Throwable { List list = cache.get(stationID); if (list == null) { - logger.warning("Departure: Cache miss " + stationID); //remove before production list = lookupDepartures(stationID); cache.put(stationID, list); } else { - logger.warning("Departure: Cache hit " + stationID); //remove before production + logger.info("Departure: Cache hit " + stationID); //remove before production } return list; } - public List lookupDepartures(int stationID) throws Exception { + public List lookupDepartures(int stationID) throws Throwable { List departureList = new ArrayList(); Connection conn = null; @@ -76,7 +76,7 @@ return departureList; } - public List lookupDepartures(String stationcode, String type) throws Exception { + public List lookupDepartures(String stationcode, String type) throws Throwable { List departureList = new ArrayList(); @@ -84,8 +84,11 @@ webClient.setTimeout(2500); webClient.setJavaScriptEnabled(false); + String uri = "http://www.bane.dk/visStation.asp?ArtikelID=4275&W=" + type + "&S=" + stationcode; + BanedkInvocation wrapper = new BanedkInvocation(webClient, uri); + CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("banedk"); - final HtmlPage page = webClient.getPage("http://www.bane.dk/visStation.asp?ArtikelID=4275&W=" + type + "&S=" + stationcode); + HtmlPage page = (HtmlPage) breaker.invoke(wrapper); HtmlElement table = page.getElementById("afgangtabel"); @@ -108,7 +111,7 @@ departure.setUpdated(updated); String trainNumber = fields.get(2).asText(); - if (trainNumber.trim().length() == 1) + if (type.equalsIgnoreCase("S2")) //If it is S-train we need to extract the trainNumber trainNumber = trainNumber + " " + extractTrainNumber(fields.get(2)); departure.setTrainNumber(trainNumber); @@ -185,7 +188,7 @@ } //test - public static void main(String args[]) throws Exception{ + public static void main(String args[]) throws Throwable { DepartureFetcher f = new DepartureFetcher(); List deps = f.lookupDepartures("AR", "FJRN"); for(DepartureBean d : deps) {