31 |
StationDAO stationDao = new StationDAO(); |
StationDAO stationDao = new StationDAO(); |
32 |
|
|
33 |
private boolean useTempSite; |
private boolean useTempSite; |
34 |
|
private int replyTimeout; |
35 |
|
|
36 |
public DepartureFetcher(boolean tempSite, int cacheTimeout) { |
public DepartureFetcher(boolean tempSite, int cacheTimeout, int replyTimeout) { |
37 |
|
this.replyTimeout = replyTimeout; |
38 |
useTempSite = tempSite; |
useTempSite = tempSite; |
39 |
cache = new TimeoutMap<String,DepartureBean>(cacheTimeout); |
cache = new TimeoutMap<String,DepartureBean>(cacheTimeout); |
40 |
} |
} |
65 |
|
|
66 |
StationBean station = stationDao.getById(stationID); |
StationBean station = stationDao.getById(stationID); |
67 |
|
|
68 |
|
departureBean.stationName = station.getName(); |
69 |
|
|
70 |
if (station.getRegional() != null) { |
if (station.getRegional() != null) { |
71 |
DepartureBean tempBean = lookupDepartures(station.getRegional(), TrainType.REGIONAL, arrival); |
DepartureBean tempBean = lookupDepartures(station.getRegional(), TrainType.REGIONAL, arrival); |
72 |
departureBean.departureEntries.addAll( tempBean.departureEntries ); |
departureBean.departureEntries.addAll( tempBean.departureEntries ); |
121 |
|
|
122 |
|
|
123 |
//logger.info("URI: " + uri); |
//logger.info("URI: " + uri); |
124 |
JsoupInvocation wrapper = new JsoupInvocation( new URL(uri), 2500); |
JsoupInvocation wrapper = new JsoupInvocation( new URL(uri), replyTimeout); |
125 |
CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("banedk"); |
CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("banedk"); |
126 |
|
|
127 |
Document page = (Document) breaker.invoke(wrapper); |
Document page = (Document) breaker.invoke(wrapper); |