本文整理了Java中org.eclipse.jetty.server.Server.setStopAtShutdown()
方法的一些代码示例,展示了Server.setStopAtShutdown()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.setStopAtShutdown()
方法的具体详情如下:
包路径:org.eclipse.jetty.server.Server
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!