You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2009/07/25 04:47:22 UTC

svn commit: r797707 - /hadoop/hbase/trunk/src/contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/Main.java

Author: apurtell
Date: Sat Jul 25 02:47:21 2009
New Revision: 797707

URL: http://svn.apache.org/viewvc?rev=797707&view=rev
Log:
put back the simple standalone embedded Jetty setup we had for Main some time ago

Modified:
    hadoop/hbase/trunk/src/contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/Main.java

Modified: hadoop/hbase/trunk/src/contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/Main.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/Main.java?rev=797707&r1=797706&r2=797707&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/Main.java (original)
+++ hadoop/hbase/trunk/src/contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/Main.java Sat Jul 25 02:47:21 2009
@@ -24,17 +24,11 @@
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.Options;
 import org.apache.commons.cli.PosixParser;
-import org.mortbay.jetty.Connector;
-import org.mortbay.jetty.Handler;
-import org.mortbay.jetty.NCSARequestLog;
 import org.mortbay.jetty.Server;
-import org.mortbay.jetty.deployer.WebAppDeployer;
-import org.mortbay.jetty.handler.ContextHandlerCollection;
-import org.mortbay.jetty.handler.DefaultHandler;
-import org.mortbay.jetty.handler.HandlerCollection;
-import org.mortbay.jetty.handler.RequestLogHandler;
-import org.mortbay.jetty.nio.SelectChannelConnector;
-import org.mortbay.thread.QueuedThreadPool;
+import org.mortbay.jetty.servlet.Context;
+import org.mortbay.jetty.servlet.ServletHolder;
+
+import com.sun.jersey.spi.container.servlet.ServletContainer;
 
 /**
  * Main class for launching Stargate as a servlet hosted by an embedded Jetty
@@ -58,45 +52,23 @@
       port = Integer.valueOf(cmd.getOptionValue("p"));
     }
 
-    /*
-     * poached from:
-     * http://jetty.mortbay.org/xref/org/mortbay/jetty/example/LikeJettyXml.html
-     */
-    String jetty_home = ".";
-    Server server = new Server();
-
-    QueuedThreadPool threadPool = new QueuedThreadPool();
-    threadPool.setMaxThreads(100);
-    server.setThreadPool(threadPool);
-
-    Connector connector = new SelectChannelConnector();
-    connector.setPort(port);
-    connector.setMaxIdleTime(30000);
-    server.setConnectors(new Connector[] { connector });
-
-    HandlerCollection handlers = new HandlerCollection();
-    ContextHandlerCollection contexts = new ContextHandlerCollection();
-    RequestLogHandler requestLogHandler = new RequestLogHandler();
-    handlers.setHandlers(new Handler[] { contexts, new DefaultHandler(), 
-    										requestLogHandler });
-    server.setHandler(handlers);
-
-    WebAppDeployer deployer1 = new WebAppDeployer();
-    deployer1.setContexts(contexts);
-    deployer1.setWebAppDir(jetty_home + "/webapps");
-    deployer1.setParentLoaderPriority(false);
-    deployer1.setExtract(true);
-    deployer1.setAllowDuplicates(false);
-    // deployer1.setDefaultsDescriptor(jetty_home + "/etc/webdefault.xml");
-    server.addLifeCycle(deployer1);
-
-    NCSARequestLog requestLog = new NCSARequestLog(jetty_home 
-    		+ "/logs/jetty-yyyy_mm_dd.log");
-    requestLog.setExtended(false);
-    requestLogHandler.setRequestLog(requestLog);
-    
+    // set up the Jersey servlet container for Jetty
+    ServletHolder sh = new ServletHolder(ServletContainer.class);
+    sh.setInitParameter(
+      "com.sun.jersey.config.property.resourceConfigClass",
+      ResourceConfig.class.getCanonicalName());
+    sh.setInitParameter("com.sun.jersey.config.property.packages",
+      "jetty");
+
+    // set up Jetty and run the embedded server
+
+    Server server = new Server(port);
+    server.setSendServerVersion(false);
+    server.setSendDateHeader(false);
     server.setStopAtShutdown(true);
-    server.setSendServerVersion(true);
+      // set up context
+    Context context = new Context(server, "/", Context.SESSIONS);
+    context.addServlet(sh, "/*");
     server.start();
     server.join();
   }