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 = null;
  18
  19         private SlcEventListenerRegister eventListenerRegister;
  20         private Long defaultTimeout = 10000l;
  21
  22         @Override
  23         protected void handleServiceRequest(HttpServletRequest request,
  24                         HttpServletResponse response, ModelAndView modelAndView)
  25                         throws Exception {
  26                 String timeoutStr = request.getParameter("timeout");
  27
  28                 final Long timeout;
  29                 if (timeoutStr != null)
  30                         timeout = Long.parseLong(timeoutStr);
  31                 else
  32                         timeout = defaultTimeout;
  33
  34                 SlcEvent event = eventListener.listen(eventListenerRegister.getId(),
  35                                 eventListenerRegister.getDescriptorsCopy(), timeout);
  36                 if (event != null) {
  37                         modelAndView.addObject("event", event);
  38
  39                         if (log.isTraceEnabled())
  40                                 log.debug("Received event: "
  41                                                 + event.getHeaders().get(SlcEvent.EVENT_TYPE));
  42                 }
  43         }
  44
  45         public void setEventListenerRegister(
  46                         SlcEventListenerRegister eventListenerRegister) {
  47                 this.eventListenerRegister = eventListenerRegister;
  48         }
  49
  50         public void setDefaultTimeout(Long defaultTimeout) {
  51                 this.defaultTimeout = defaultTimeout;
  52         }
  53
  54         public void setEventListener(SlcEventListener eventListener) {
  55                 this.eventListener = eventListener;
  56         }
  57
  58 }