runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/web/mvc/event/PollEventController.java

   1 package org.argeo.slc.web.mvc.event;
   2
   3 import javax.servlet.http.HttpServletRequest;
   4 import javax.servlet.http.HttpServletResponse;
   5
   6 import org.apache.commons.logging.Log;
   7 import org.apache.commons.logging.LogFactory;
   8 import org.argeo.slc.msg.event.SlcEvent;
   9 import org.argeo.slc.msg.event.SlcEventListener;
  10 import org.argeo.slc.msg.event.SlcEventListenerRegister;
  11 import org.argeo.slc.web.mvc.AbstractServiceController;
  12 import org.springframework.web.servlet.ModelAndView;
  13
  14 public class PollEventController extends AbstractServiceController {
  15         private final static Log log = LogFactory.getLog(PollEventController.class);
  16
  17         private SlcEventListener eventListener;
  18         private SlcEventListenerRegister eventListenerRegister;
  19         private Long defaultTimeout = 10000l;
  20
  21         @Override
  22         protected void handleServiceRequest(HttpServletRequest request,
  23                         HttpServletResponse response, ModelAndView modelAndView)
  24                         throws Exception {
  25                 String timeoutStr = request.getParameter("timeout");
  26
  27                 final Long timeout;
  28                 if (timeoutStr != null)
  29                         timeout = Long.parseLong(timeoutStr);
  30                 else
  31                         timeout = defaultTimeout;
  32
  33                 SlcEvent event = eventListener.listen(eventListenerRegister, timeout);
  34                 if (event != null) {
  35                         modelAndView.addObject("event", event);
  36
  37                         if (log.isTraceEnabled())
  38                                 log.debug("Received event: "
  39                                                 + event.getHeaders().get(SlcEvent.EVENT_TYPE));
  40                 }
  41         }
  42
  43         public void setEventListener(SlcEventListener slcEventListener) {
  44                 this.eventListener = slcEventListener;
  45         }
  46
  47         public void setEventListenerRegister(
  48                         SlcEventListenerRegister eventListenerRegister) {
  49                 this.eventListenerRegister = eventListenerRegister;
  50         }
  51
  52         public void setDefaultTimeout(Long defaultTimeout) {
  53                 this.defaultTimeout = defaultTimeout;
  54         }
  55
  56 }