remote/SimpleSessionProvider.java

   1 package org.argeo.jackrabbit.remote;
   2
   3 import java.io.Serializable;
   4 import java.util.Collections;
   5 import java.util.HashMap;
   6 import java.util.Map;
   7
   8 import javax.jcr.LoginException;
   9 import javax.jcr.Repository;
  10 import javax.jcr.RepositoryException;
  11 import javax.jcr.Session;
  12 import javax.servlet.ServletException;
  13 import javax.servlet.http.HttpServletRequest;
  14
  15 import org.apache.commons.logging.Log;
  16 import org.apache.commons.logging.LogFactory;
  17 import org.apache.jackrabbit.server.SessionProvider;
  18 import org.argeo.ArgeoException;
  19
  20 /** To be injected, typically of scope="session" */
  21 public class SimpleSessionProvider implements SessionProvider, Serializable {
  22         private static final long serialVersionUID = 2270957712453841368L;
  23
  24         private final static Log log = LogFactory
  25                         .getLog(SimpleSessionProvider.class);
  26
  27         private transient Map<String, Session> sessions;
  28
  29         public Session getSession(HttpServletRequest request, Repository rep,
  30                         String workspace) throws LoginException, ServletException,
  31                         RepositoryException {
  32                 // since sessions is transient it can't be restored from the session
  33                 if (sessions == null)
  34                         sessions = Collections
  35                                         .synchronizedMap(new HashMap<String, Session>());
  36
  37                 if (!sessions.containsKey(workspace)) {
  38                         try {
  39                                 Session session = rep.login(null, workspace);
  40                                 if (log.isTraceEnabled())
  41                                         log.trace("User " + session.getUserID() + " logged into "
  42                                                         + request.getServletPath());
  43                                 sessions.put(workspace, session);
  44                                 return session;
  45                         } catch (Exception e) {
  46                                 throw new ArgeoException("Cannot open session", e);
  47                         }
  48                 } else {
  49                         Session session = sessions.get(workspace);
  50                         if (!session.isLive()) {
  51                                 sessions.remove(workspace);
  52                                 session = rep.login(null, workspace);
  53                                 sessions.put(workspace, session);
  54                         }
  55                         return session;
  56                 }
  57         }
  58
  59         public void releaseSession(Session session) {
  60                 if (log.isTraceEnabled())
  61                         log.trace("Releasing JCR session " + session);
  62         }
  63
  64         public void init() {
  65         }
  66
  67         public void dispose() {
  68                 if (sessions != null)
  69                         for (String workspace : sessions.keySet()) {
  70                                 Session session = sessions.get(workspace);
  71                                 if (session.isLive())
  72                                         session.logout();
  73                         }
  74         }
  75 }