org.eclipse.jetty.server.Server.setStopAtShutdown()方法的使用及代码示例

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

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

Server.setStopAtShutdown介绍

[英]Set stop server at shutdown behaviour.
[中]将停止服务器设置为关机行为。

代码示例

代码示例来源:origin: jphp-group/jphp

@Signature
public void stopAtShutdown(boolean val) {
  server.setStopAtShutdown(val);
}

代码示例来源:origin: apache/hbase

connector.setPort(infoPort);
masterJettyServer.addConnector(connector);
masterJettyServer.setStopAtShutdown(true);

代码示例来源:origin: org.springframework.boot/spring-boot

private void initialize() {
  synchronized (this.monitor) {
    try {
      // Cache the connectors and then remove them to prevent requests being
      // handled before the application context is ready.
      this.connectors = this.server.getConnectors();
      this.server.addBean(new AbstractLifeCycle() {
        @Override
        protected void doStart() throws Exception {
          for (Connector connector : JettyWebServer.this.connectors) {
            Assert.state(connector.isStopped(), () -> "Connector "
                + connector + " has been started prematurely");
          }
          JettyWebServer.this.server.setConnectors(null);
        }
      });
      // Start the server so that the ServletContext is available
      this.server.start();
      this.server.setStopAtShutdown(false);
    }
    catch (Throwable ex) {
      // Ensure process isn't left running
      stopSilently();
      throw new WebServerException("Unable to start embedded Jetty web server",
          ex);
    }
  }
}

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

@Test
public void shouldSetStopAtShutdown() throws Exception {
  jetty9Server.configure();
  verify(server).setStopAtShutdown(true);
}

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

addDefaultServlet(wac);
server.setHandler(wac);
server.setStopAtShutdown(true);
server.start();

代码示例来源:origin: jooby-project/jooby

server.setStopAtShutdown(false);

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

protected Server buildServer(LifecycleEnvironment lifecycle,
               ThreadPool threadPool) {
  final Server server = new Server(threadPool);
  server.addLifeCycleListener(buildSetUIDListener());
  lifecycle.attach(server);
  final ErrorHandler errorHandler = new ErrorHandler();
  errorHandler.setServer(server);
  errorHandler.setShowStacks(false);
  server.addBean(errorHandler);
  server.setStopAtShutdown(true);
  server.setStopTimeout(shutdownGracePeriod.toMilliseconds());
  return server;
}

代码示例来源:origin: apache/hbase

serverConnector.setHost(getBindAddress(conf).getHostAddress());
httpServer.addConnector(serverConnector);
httpServer.setStopAtShutdown(true);

代码示例来源:origin: loklak/loklak_server

pool.setMaxThreads(500);
LoklakInstallation.server = new Server(pool);
LoklakInstallation.server.setStopAtShutdown(true);

代码示例来源:origin: loklak/loklak_server

pool.start();
LoklakServer.server = new Server(pool);
LoklakServer.server.setStopAtShutdown(true);

代码示例来源:origin: apache/ignite

httpSrv.setStopAtShutdown(false);

代码示例来源:origin: apache/hbase

server.setStopAtShutdown(true);

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

@Override
public void configure() throws Exception {
  server.addEventListener(mbeans());
  server.addConnector(plainConnector());
  server.addConnector(sslConnector());
  ContextHandlerCollection handlers = new ContextHandlerCollection();
  deploymentManager.setContexts(handlers);
  createWebAppContext();
  JettyCustomErrorPageHandler errorHandler = new JettyCustomErrorPageHandler();
  webAppContext.setErrorHandler(errorHandler);
  webAppContext.setGzipHandler(gzipHandler());
  server.addBean(errorHandler);
  server.addBean(deploymentManager);
  HandlerCollection serverLevelHandlers = new HandlerCollection();
  serverLevelHandlers.setHandlers(new Handler[]{handlers});
  server.setHandler(serverLevelHandlers);
  performCustomConfiguration();
  server.setStopAtShutdown(true);
}

代码示例来源:origin: allure-framework/allure1

/**
   * Set up server for report directory.
   */
  private Server setUpServer() {
    Server server = new Server(port);
    ResourceHandler handler = new ResourceHandler();
    handler.setDirectoriesListed(true);
    handler.setWelcomeFiles(new String[]{"index.html"});
    handler.setResourceBase(getReportDirectoryPath().toAbsolutePath().toString());
    HandlerList handlers = new HandlerList();
    handlers.setHandlers(new Handler[]{handler, new DefaultHandler()});
    server.setStopAtShutdown(true);
    server.setHandler(handlers);
    return server;
  }
}

代码示例来源:origin: rnewson/couchdb-lucene

/**
 * Run couchdb-lucene.
 */
public static void main(String[] args) throws Exception {
  final Config config = new Config();
  final File dir = config.getDir();
  final Server server = new Server();
  final ServerConnector connector = new ServerConnector(server);
  connector.setHost(config.getConfiguration().getString("lucene.host", "localhost"));
  connector.setPort(config.getConfiguration().getInt("lucene.port", 5985));
  LOG.info("Accepting connections with " + connector);
  server.addConnector(connector);
  server.setStopAtShutdown(true);
  final LuceneServlet servlet = new LuceneServlet(config.getClient(), dir, config.getConfiguration());
  final ServletContextHandler context = new ServletContextHandler(server, "/",
      ServletContextHandler.NO_SESSIONS | ServletContextHandler.NO_SECURITY);
  context.addServlet(new ServletHolder(servlet), "/*");
  context.setErrorHandler(new JSONErrorHandler());
  context.setGzipHandler(new GzipHandler());
  server.setHandler(context);
  server.start();
  server.join();
}

代码示例来源:origin: yacy/yacy_grid_mcp

connector.setIdleTimeout(20000); // timout in ms when no bytes send / received
server.addConnector(connector);
server.setStopAtShutdown(true);

代码示例来源:origin: io.dropwizard/dropwizard-core

protected Server buildServer(LifecycleEnvironment lifecycle,
               ThreadPool threadPool) {
  final Server server = new Server(threadPool);
  server.addLifeCycleListener(buildSetUIDListener());
  lifecycle.attach(server);
  final ErrorHandler errorHandler = new ErrorHandler();
  errorHandler.setServer(server);
  errorHandler.setShowStacks(false);
  server.addBean(errorHandler);
  server.setStopAtShutdown(true);
  server.setStopTimeout(shutdownGracePeriod.toMilliseconds());
  return server;
}

代码示例来源:origin: apache/cloudstack

server.setStopAtShutdown(true);

代码示例来源:origin: io.nflow/nflow-jetty

private Server setupServer() {
 Server server = new Server(new QueuedThreadPool(100));
 server.setStopAtShutdown(true);
 return server;
}

代码示例来源:origin: kumuluz/kumuluzee

public Server create() {
  Log.setLog(new JavaUtilLog());
  Server server = new Server(createThreadPool());
  server.addBean(createClassList());
  server.setStopAtShutdown(true);
  server.setConnectors(createConnectors(server));
  return server;
}

相关文章

微信公众号

最新文章

更多