/[projects]/android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/TimetableServlet.java
ViewVC logotype

Diff of /android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/TimetableServlet.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 859 by torben, Wed Jun 16 08:20:01 2010 UTC revision 1303 by torben, Tue Apr 19 11:52:39 2011 UTC
# Line 1  Line 1 
1  package dk.thoerup.traininfoservice.banedk;  package dk.thoerup.traininfoservice.banedk;
2    
3  import java.io.IOException;  import java.io.IOException;
4  import java.util.List;  import java.io.StringWriter;
5    
6  import java.util.logging.Level;  import java.util.logging.Level;
7  import java.util.logging.Logger;  import java.util.logging.Logger;
8    
9  import javax.servlet.ServletException;  import javax.servlet.ServletException;
10    import javax.servlet.annotation.WebServlet;
11  import javax.servlet.http.HttpServlet;  import javax.servlet.http.HttpServlet;
12  import javax.servlet.http.HttpServletRequest;  import javax.servlet.http.HttpServletRequest;
13  import javax.servlet.http.HttpServletResponse;  import javax.servlet.http.HttpServletResponse;
14    
15    import org.simpleframework.xml.Serializer;
16    import org.simpleframework.xml.core.Persister;
17    
18    import dk.thoerup.android.traininfo.common.TimetableBean;
19  import dk.thoerup.circuitbreaker.CircuitBreakerException;  import dk.thoerup.circuitbreaker.CircuitBreakerException;
20  import dk.thoerup.traininfoservice.Statistics;  import dk.thoerup.traininfoservice.Statistics;
21    import dk.thoerup.traininfoservice.TraininfoSettings;;
22    
23  /**  /**
24   * Servlet implementation class TimetableServlet   * Servlet implementation class TimetableServlet
25   */   */
26    @WebServlet(urlPatterns={"/TimetableServlet"})
27  public class TimetableServlet extends HttpServlet {  public class TimetableServlet extends HttpServlet {
28          private static final long serialVersionUID = 1L;          private static final long serialVersionUID = 1L;
29                
# Line 24  public class TimetableServlet extends Ht Line 32  public class TimetableServlet extends Ht
32                    
33          TimetableFetcher fetcher;          TimetableFetcher fetcher;
34                    
35            
36          @Override          @Override
37          public void init() throws ServletException {          public void init() throws ServletException {
38                  super.init();                  super.init();
39                                    
40                  boolean useTempSite =  Boolean.parseBoolean( getServletContext().getInitParameter("usetempsite") );  
41                  int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );                  TraininfoSettings settings = (TraininfoSettings) getServletContext().getAttribute("settings");
42                  logger.info( "TimetableServlet, use temp site=" + useTempSite + ", cache=" + cacheTimeout);                  fetcher = new TimetableFetcher(settings);
                 fetcher = new TimetableFetcher(useTempSite,cacheTimeout);  
43          }          }
44                    
45          @Override          @Override
# Line 51  public class TimetableServlet extends Ht Line 59  public class TimetableServlet extends Ht
59                                                                    
60                  try                  try
61                  {                  {
62                          List<TimetableBean> timetable = fetcher.cachedLookupTimetable(train, type);                          TimetableBean timetable = fetcher.cachedLookupTimetable(train, type);
63                                    
64                          String responseXML = formatTimetable(timetable);                          String responseXML = formatTimetable(timetable);
65                                    
# Line 62  public class TimetableServlet extends Ht Line 70  public class TimetableServlet extends Ht
70                          Statistics.getInstance().incrementTimetableErrors();                          Statistics.getInstance().incrementTimetableErrors();
71                          response.sendError(500, "Backend timed out");                          response.sendError(500, "Backend timed out");
72                  } catch (CircuitBreakerException cbe) {                  } catch (CircuitBreakerException cbe) {
73                          logger.warning("Circuitbreaker - failing fast");                          logger.warning("Circuitbreaker - failing fast, type=" + type + ", train="+train);
74                          Statistics.getInstance().incrementTimetableErrors();                          Statistics.getInstance().incrementTimetableErrors();
75                          response.sendError(500);                          response.sendError(500);
76                  }catch (Exception e) {                  }catch (Exception e) {
# Line 73  public class TimetableServlet extends Ht Line 81  public class TimetableServlet extends Ht
81                                    
82          }          }
83                    
84          String formatTimetable(List<TimetableBean> timetable) {          String formatTimetable(TimetableBean timetable) throws ServletException {
85                  StringBuffer sb = new StringBuffer();                  Serializer serializer = new Persister();
86                  //sb.append("<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n");  
87                                    StringWriter out = new StringWriter();
88                  sb.append("<timetable>");  
89                                    try {
90                  for (TimetableBean bean : timetable) {                          serializer.write(timetable, out);
91                          sb.append("<entry");                  } catch (Exception e) {
92                          if (bean.isCurrent())                          throw new ServletException(e);
                                 sb.append(" current=\"true\"");  
                         sb.append(">");  
                           
                         sb.append("<station>").append( bean.getStation() ).append("</station>");  
                         sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");  
                         sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");  
                         sb.append("<stationid>").append( bean.getStationId() ).append("</stationid>");  
                           
                         sb.append("</entry>");  
93                  }                  }
94                                    
95                  sb.append("</timetable>");                  return out.toString();
                   
                 return sb.toString();  
96          }          }
97    
98  }  }
Legend:
Removed from v.859  
changed lines
  Added in v.1303
  ViewVC Help
Powered by ViewVC 1.1.20