本文整理了Java中com.linkedin.r2.transport.http.server.HttpServer.stop()
方法的一些代码示例,展示了HttpServer.stop()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpServer.stop()
方法的具体详情如下:
包路径:com.linkedin.r2.transport.http.server.HttpServer
类名称:HttpServer
方法名:stop
暂无
代码示例来源:origin: apache/incubator-gobblin
@Override
protected void shutDown()
throws Exception {
if (this.httpServer.isPresent()) {
LOGGER.info("Stopping the job execution information server");
this.httpServer.get().stop();
}
}
代码示例来源:origin: apache/incubator-gobblin
@Override
protected void shutDown() throws Exception {
if (this.httpServer.isPresent()) {
this.log.info("Stopping the {} embedded server at port {}", this.name, this.port);
this.httpServer.get().stop();
this.httpServer.get().waitForStop();
}
}
代码示例来源:origin: linkedin/parseq
@AfterClass
public void shutdown() throws Exception {
if (_server != null) {
_server.stop();
}
if (_serverEngine != null) {
_serverEngine.shutdown();
}
if (_serverScheduler != null) {
_serverScheduler.shutdownNow();
}
for (Client client : _transportClients) {
FutureCallback<None> callback = new FutureCallback<>();
client.shutdown(callback);
callback.get();
}
if (_clientFactory != null) {
FutureCallback<None> callback = new FutureCallback<>();
_clientFactory.shutdown(callback);
callback.get();
}
}
代码示例来源:origin: com.linkedin.pegasus/restli-server-standalone
/**
* Stop the server
*
* @throws IOException server shutdown fails
*/
public void stop() throws IOException
{
_server.stop();
}
代码示例来源:origin: com.linkedin.gobblin/gobblin-rest-server
@Override
protected void shutDown()
throws Exception {
if (this.httpServer.isPresent()) {
LOGGER.info("Stopping the job execution information server");
this.httpServer.get().stop();
}
}
代码示例来源:origin: org.apache.gobblin/gobblin-rest-server
@Override
protected void shutDown()
throws Exception {
if (this.httpServer.isPresent()) {
LOGGER.info("Stopping the job execution information server");
this.httpServer.get().stop();
}
}
代码示例来源:origin: com.linkedin.pegasus/restli-server-testutils
@Override
public void stop()
throws IOException
{
server.stop();
engine.shutdown();
executor.shutdown();
scheduler.shutdown();
}
代码示例来源:origin: org.apache.gobblin/gobblin-restli-utils
@Override
protected void shutDown() throws Exception {
if (this.httpServer.isPresent()) {
this.log.info("Stopping the {} embedded server at port {}", this.name, this.port);
this.httpServer.get().stop();
this.httpServer.get().waitForStop();
}
}
代码示例来源:origin: com.linkedin.pegasus/restli-int-test-server
public static void main(String[] args) throws IOException
{
final int numCores = Runtime.getRuntime().availableProcessors();
final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(numCores + 1);
final Engine engine = new EngineBuilder()
.setTaskExecutor(scheduler)
.setTimerScheduler(scheduler)
.build();
HttpServer server = createServer(engine, DEFAULT_PORT, supportedCompression);
server.start();
System.out.println("HttpServer running on port " + DEFAULT_PORT + ". Press any key to stop server");
System.in.read();
server.stop();
engine.shutdown();
}
内容来源于网络,如有侵权,请联系作者删除!