/[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 1158 by torben, Mon Oct 4 05:51:55 2010 UTC revision 1396 by torben, Thu Apr 28 10:13:36 2011 UTC
# Line 1  Line 1 
1  package dk.thoerup.traininfoservice.banedk;  package dk.thoerup.traininfoservice.banedk;
2    
 import java.io.ByteArrayOutputStream;  
3  import java.io.IOException;  import java.io.IOException;
4    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;
# Line 15  import javax.servlet.http.HttpServletRes Line 15  import javax.servlet.http.HttpServletRes
15  import org.simpleframework.xml.Serializer;  import org.simpleframework.xml.Serializer;
16  import org.simpleframework.xml.core.Persister;  import org.simpleframework.xml.core.Persister;
17    
18    import dk.thoerup.android.traininfo.common.DepartureBean;
19  import dk.thoerup.android.traininfo.common.TimetableBean;  import dk.thoerup.android.traininfo.common.TimetableBean;
20  import dk.thoerup.circuitbreaker.CircuitBreakerException;  import dk.thoerup.circuitbreaker.CircuitBreakerException;
21  import dk.thoerup.traininfoservice.Statistics;  import dk.thoerup.traininfoservice.Statistics;
22    import dk.thoerup.traininfoservice.TraininfoSettings;;
23    
24  /**  /**
25   * Servlet implementation class TimetableServlet   * Servlet implementation class TimetableServlet
# Line 36  public class TimetableServlet extends Ht Line 38  public class TimetableServlet extends Ht
38          public void init() throws ServletException {          public void init() throws ServletException {
39                  super.init();                  super.init();
40                                    
41                  boolean useAzureSite =  Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );  
42                  int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );                  TraininfoSettings settings = (TraininfoSettings) getServletContext().getAttribute("settings");
43                  int replyTimeout =  Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );                  fetcher = new TimetableFetcher(settings);
                 logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);  
                 fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);  
44          }          }
45                    
46          @Override          @Override
# Line 57  public class TimetableServlet extends Ht Line 57  public class TimetableServlet extends Ht
57                                    
58                  String train = request.getParameter("train").trim();                  String train = request.getParameter("train").trim();
59                  String type = request.getParameter("type").trim();                  String type = request.getParameter("type").trim();
60                                                            
61                    
62                    TimetableBean timetable = null;
63                  try                  try
64                  {                  {
65                          TimetableBean timetable = fetcher.cachedLookupTimetable(train, type);                          timetable = fetcher.cachedLookupTimetable(train, type);
                   
                         String responseXML = formatTimetable(timetable);  
66                                    
                         response.setContentType("text/xml");  
                         response.getWriter().print(responseXML);  
67                  } catch (java.io.IOException ioe) {                  } catch (java.io.IOException ioe) {
68                          logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());                          logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
69                          Statistics.getInstance().incrementTimetableErrors();                          Statistics.getInstance().incrementTimetableErrors();
70                          response.sendError(500, "Backend timed out");                          //timetable = generateErrorBean(1);
71                            response.sendError( 500, "Backend didn't answer" );
72                  } catch (CircuitBreakerException cbe) {                  } catch (CircuitBreakerException cbe) {
73                          logger.warning("Circuitbreaker - failing fast, type=" + type + ", train="+train);                          logger.warning("Circuitbreaker - failing fast, type=" + type + ", train="+train);
74                          Statistics.getInstance().incrementTimetableErrors();                          Statistics.getInstance().incrementTimetableErrors();                    
75                          response.sendError(500);                          timetable = generateErrorBean(1);
76                  }catch (Exception e) {                  }catch (Exception e) {
77                          logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);                          logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
78                          Statistics.getInstance().incrementTimetableErrors();                          Statistics.getInstance().incrementTimetableErrors();
79                          response.sendError(500);                          response.sendError(500);
80                  }                  }
81                                    
82                    if (timetable != null) {
83                            String responseXML = formatTimetable(timetable);
84                    
85                            response.setContentType("text/xml");
86                            response.getWriter().print(responseXML);
87                    }
88                    
89            }
90            
91            protected TimetableBean generateErrorBean(int code) {
92                    TimetableBean bean = new TimetableBean();              
93                    bean.errorCode = code;
94                    return bean;
95          }          }
96                    
97          String formatTimetable(TimetableBean timetable) throws ServletException {          String formatTimetable(TimetableBean timetable) throws ServletException {
98                  Serializer serializer = new Persister();                  Serializer serializer = new Persister();
99    
100                  ByteArrayOutputStream out = new ByteArrayOutputStream();                  StringWriter out = new StringWriter();
101    
102                  try {                  try {
103                          serializer.write(timetable, out);                          serializer.write(timetable, out);
Legend:
Removed from v.1158  
changed lines
  Added in v.1396
  ViewVC Help
Powered by ViewVC 1.1.20