You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by db...@apache.org on 2010/11/11 19:39:28 UTC

svn commit: r1034030 - /openejb/branches/openejb-3.1.x/server/openejb-http/src/main/java/org/apache/openejb/server/httpd/JettyHttpServer.java

Author: dblevins
Date: Thu Nov 11 18:39:28 2010
New Revision: 1034030

URL: http://svn.apache.org/viewvc?rev=1034030&view=rev
Log:
OPENEJB-1395: Install Jetty SessionHandler when Jetty is used to power @WebService HTTP requests

Modified:
    openejb/branches/openejb-3.1.x/server/openejb-http/src/main/java/org/apache/openejb/server/httpd/JettyHttpServer.java

Modified: openejb/branches/openejb-3.1.x/server/openejb-http/src/main/java/org/apache/openejb/server/httpd/JettyHttpServer.java
URL: http://svn.apache.org/viewvc/openejb/branches/openejb-3.1.x/server/openejb-http/src/main/java/org/apache/openejb/server/httpd/JettyHttpServer.java?rev=1034030&r1=1034029&r2=1034030&view=diff
==============================================================================
--- openejb/branches/openejb-3.1.x/server/openejb-http/src/main/java/org/apache/openejb/server/httpd/JettyHttpServer.java (original)
+++ openejb/branches/openejb-3.1.x/server/openejb-http/src/main/java/org/apache/openejb/server/httpd/JettyHttpServer.java Thu Nov 11 18:39:28 2010
@@ -33,9 +33,13 @@ import org.mortbay.jetty.Connector;
 import org.mortbay.jetty.Handler;
 import org.mortbay.jetty.Request;
 import org.mortbay.jetty.Server;
+import org.mortbay.jetty.SessionManager;
 import org.mortbay.jetty.handler.AbstractHandler;
 import org.mortbay.jetty.handler.ContextHandler;
 import org.mortbay.jetty.nio.SelectChannelConnector;
+import org.mortbay.jetty.servlet.HashSessionIdManager;
+import org.mortbay.jetty.servlet.HashSessionManager;
+import org.mortbay.jetty.servlet.SessionHandler;
 
 /**
  * Jetty based http server implementation
@@ -81,7 +85,7 @@ public class JettyHttpServer implements 
         Options options = new Options(props);
 
         port = options.get("port", 8080);
-        
+
         // Create all the Jetty objects but dont' start them
         server = new Server();
         Connector connector = new SelectChannelConnector();
@@ -110,7 +114,13 @@ public class JettyHttpServer implements 
             }
         };
 
-        context.setHandler(handler);
+        SessionHandler sessionHandler = new SessionHandler();
+        SessionManager sessionManager = new HashSessionManager();
+        sessionManager.setIdManager(new HashSessionIdManager());
+        sessionHandler.setSessionManager(sessionManager);
+        sessionHandler.setHandler(handler);
+
+        context.setHandler(sessionHandler);
     }
 
     public void start() throws ServiceException {