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

   1 package org.argeo.slc.web.mvc;
   2
   3 import java.io.Serializable;
   4 import java.util.ArrayList;
   5 import java.util.List;
   6 import java.util.Vector;
   7
   8 import org.apache.commons.logging.Log;
   9 import org.apache.commons.logging.LogFactory;
  10 import org.argeo.slc.msg.event.SlcEventListenerDescriptor;
  11 import org.argeo.slc.msg.event.SlcEventListenerRegister;
  12 import org.springframework.web.context.request.RequestContextHolder;
  13
  14 public class WebSlcEventListenerRegister implements SlcEventListenerRegister,
  15                 Serializable {
  16         private final static Log log = LogFactory
  17                         .getLog(WebSlcEventListenerRegister.class);
  18         public final static String ATTR_EVENT_LISTENER = "slcEventListener";
  19
  20         static final long serialVersionUID = 1l;
  21
  22         //private String clientId = UUID.randomUUID().toString();
  23
  24         /** Synchronized */
  25         private List<SlcEventListenerDescriptor> descriptors = new Vector<SlcEventListenerDescriptor>();
  26
  27         public synchronized void addEventListenerDescriptor(
  28                         SlcEventListenerDescriptor eventListenerDescriptor) {
  29                 if (descriptors.contains(eventListenerDescriptor))
  30                         descriptors.remove(eventListenerDescriptor);
  31                 descriptors.add(eventListenerDescriptor);
  32         }
  33
  34         public synchronized void removeEventListenerDescriptor(
  35                         SlcEventListenerDescriptor eventListenerDescriptor) {
  36                 descriptors.remove(eventListenerDescriptor);
  37         }
  38
  39         public synchronized List<SlcEventListenerDescriptor> getDescriptorsCopy() {
  40                 return new ArrayList<SlcEventListenerDescriptor>(descriptors);
  41         }
  42
  43         // public SlcEvent listen(SlcEventListener eventListener, Long timeout) {
  44         // return eventListener.listen(clientId, getDescriptorsCopy(), timeout);
  45         // }
  46
  47         // public void init() {
  48         // clientId = getSessionId();
  49         // checkClientId();
  50         //
  51         // if (log.isDebugEnabled())
  52         // log.debug("Initialized web event listener " + clientId);
  53         // }
  54         //
  55         // public void close() {
  56         // checkClientId();
  57         // if (log.isDebugEnabled())
  58         // log.debug("Closed web event listener " + clientId);
  59         // }
  60
  61         // protected void checkClientId() {
  62         // String sessionId = getSessionId();
  63         // if (clientId == null || !clientId.equals(sessionId))
  64         // throw new SlcException("Client id " + clientId
  65         // + " not consistent with web session id " + sessionId);
  66         // }
  67         //
  68         // protected String getSessionId() {
  69         // return RequestContextHolder.currentRequestAttributes().getSessionId();
  70         // }
  71         //
  72         public String getId() {
  73                 return RequestContextHolder.currentRequestAttributes().getSessionId();
  74         }
  75
  76 }