org.mortbay.jetty.Server.start()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中org.mortbay.jetty.Server.start()方法的一些代码示例,展示了Server.start()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.start()方法的具体详情如下:
包路径:org.mortbay.jetty.Server
类名称:Server
方法名:start

Server.start介绍

暂无

代码示例

代码示例来源:origin: soabase/exhibitor

public void start() throws Exception
{
  server.start();
}

代码示例来源:origin: tjake/Solandra

public void start(boolean waitForSolr) throws Exception
{
 if(!server.isRunning() ) {
  server.start();
 }
 if (waitForSolr) waitForSolr(context);
}

代码示例来源:origin: ltsopensource/light-task-scheduler

server.setHandler(webapp);
server.setStopAtShutdown(true);
server.start();

代码示例来源:origin: Netflix/eureka

public void start() throws Exception {
  server.start();
  port = server.getConnectors()[0].getLocalPort();
}

代码示例来源:origin: azkaban/azkaban

private void prepareAndStartServer()
  throws Exception {
 validateDatabaseVersion();
 createThreadPool();
 configureRoutes();
 // Todo jamiesjc: enable web metrics for azkaban poll model later
 if (this.props.getBoolean(Constants.ConfigurationKeys.IS_METRICS_ENABLED, false)
   && !this.props.getBoolean(ConfigurationKeys.AZKABAN_POLL_MODEL, false)) {
  startWebMetrics();
 }
 if (this.props.getBoolean(ConfigurationKeys.ENABLE_QUARTZ, false)) {
  // flowTriggerService needs to be started first before scheduler starts to schedule
  // existing flow triggers
  logger.info("starting flow trigger service");
  this.flowTriggerService.start();
  logger.info("starting flow trigger scheduler");
  this.scheduler.start();
 }
 try {
  this.server.start();
  logger.info("Server started");
 } catch (final Exception e) {
  logger.warn(e);
  Utils.croak(e.getMessage(), 1);
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

public String getRedirectUri() throws IOException {
 if ( this.port == -1 ) {
  this.port = getUnusedPort();
 }
 this.server = new Server( this.port );
 Connector[] arr$ = this.server.getConnectors();
 int len$ = arr$.length;
 for ( int i$ = 0; i$ < len$; ++i$ ) {
  Connector c = arr$[i$];
  c.setHost( this.host );
 }
 this.server.addHandler( new CustomLocalServerReceiver.CallbackHandler() );
 try {
  this.server.start();
 } catch ( Exception var5 ) {
  Throwables.propagateIfPossible( var5 );
  throw new IOException( var5 );
 }
 return "http://" + this.host + ":" + this.port + "/Callback/success.html";
}

代码示例来源:origin: twitter/ambrose

server.start();
 server.join();
} catch (Exception e) {

代码示例来源:origin: Netflix/eureka

public void start() throws Exception {
  server = new Server(port);
  server.setHandler(new AppsResourceHandler());
  server.start();
  port = server.getConnectors()[0].getLocalPort();
}

代码示例来源:origin: testcontainers/testcontainers-java

@Before
public void setupLocalServer() throws Exception {
  // Set up a local Jetty HTTP server
  Server server = new Server();
  server.addConnector(new SocketConnector());
  ResourceHandler resourceHandler = new ResourceHandler();
  resourceHandler.setResourceBase("src/test/resources/server");
  server.addHandler(resourceHandler);
  server.start();
  // The server will have a random port assigned, so capture that
  localPort = server.getConnectors()[0].getLocalPort();
}

代码示例来源:origin: rhuss/jolokia

/**
 * Startup the HTTP server
 *
 * @throws StartException if starting fails
 */
public void start() throws StartException {
  try {
    server.start();
  } catch (Exception e) {
    throw new StartException(e, parent);
  }
}

代码示例来源:origin: voldemort/voldemort

public static Context getJettyServer(String clusterXml,
                   String storesXml,
                   String storeName,
                   RequestFormatType requestFormat,
                   int port) throws Exception {
  StoreRepository repository = getStores(storeName, clusterXml, storesXml);
  // initialize servlet
  Server server = new Server(port);
  server.setSendServerVersion(false);
  Context context = new Context(server, "/", Context.NO_SESSIONS);
  RequestHandler handler = getSocketRequestHandlerFactory(clusterXml, storesXml, repository).getRequestHandler(requestFormat);
  context.addServlet(new ServletHolder(new StoreServlet(handler)), "/stores");
  server.start();
  return context;
}

代码示例来源:origin: voldemort/voldemort

this.context = context;
  this.httpServer = httpServer;
  this.httpServer.start();
  logger.info("HTTP service started on port " + this.port);
} catch(Exception e) {

代码示例来源:origin: mapsforge/mapsforge

@Before
public final void beforeTest() throws Exception {
  Assert.assertFalse(this.httpRoot.exists());
  Assert.assertTrue(this.httpRoot.mkdirs());
  Context context = new Context(this.server, "/", Context.SESSIONS);
  context.setBaseResource(new FileResource(new URL("file://" + this.httpRoot.getAbsolutePath())));
  context.setContextPath("/");
  context.addServlet(new ServletHolder(new DefaultServlet()), "/*");
  this.server.setHandler(context);
  this.server.start();
}

代码示例来源:origin: info.aduna.commons/aduna-commons-net-http-server-embedded

public void start()
  throws Exception
{
  jetty.start();
}

代码示例来源:origin: it.unimi.dsi/mg4j-big

public void run() {
    try {
      SERVER.start();
    }
    catch ( Exception e ) {
      throw new RuntimeException();
    }
  }
}.start();

代码示例来源:origin: org.ctoolkit.test/ctoolkit-test

public void start()
  {
    try
    {
      server.start();
    }
    catch ( Exception e )
    {
      throw new RuntimeException( e );
    }
  }
}

代码示例来源:origin: org.dspace.dependencies.solr/dspace-solr-server

public void start(boolean waitForSolr) throws Exception
{
 if(!server.isRunning() ) {
  server.start();
 }
 if (waitForSolr) waitForSolr(context);
}

代码示例来源:origin: org.mortbay.jetty/jetty-embedded

public static void main(String[] args)
  throws Exception
{
  Server server = new Server();
  Connector connector=new SocketConnector();
  connector.setPort(8080);
  server.setConnectors(new Connector[]{connector});
  
  Handler handler=new HelloHandler();
  server.setHandler(handler);
  
  server.start();
  server.join();
}

代码示例来源:origin: org.apache.axis2/axis2-transport-testkit

@Setup @SuppressWarnings("unused")
private void setUp(HttpTestEnvironment env) throws Exception {
  server = new Server();
  SocketListener listener = new SocketListener();
  listener.setPort(env.getServerPort());
  server.addListener(listener);
  context = new HttpContext(server, Channel.CONTEXT_PATH + "/*");
  server.start();
}

代码示例来源:origin: org.apache.avro/avro-ipc

public StatsServer(StatsPlugin plugin, int port) throws Exception {
 this.httpServer = new Server(port);
 this.plugin = plugin;
 Context staticContext = new Context(httpServer, "/static");
 staticContext.addServlet(new ServletHolder(new StaticServlet()), "/");
 Context context = new Context(httpServer, "/");
 context.addServlet(new ServletHolder(new StatsServlet(plugin)), "/");
 httpServer.start();
}

相关文章